Operator extends ConfigurableSopremoType implements
		ISopremoType, JsonStream, Cloneable { public List<JsonStream> getInputs() { return new ArrayList<JsonStream>(this.inputs); } Operator();  Operator(final int minInputs, final int maxInputs, final int minOutputs, final int maxOutputs); @Override void appendAsString(final Appendable appendable); abstract ElementarySopremoModule asElementaryOperators(); @SuppressWarnings("unchecked") @Override Operator<Self> clone(); @Override boolean equals(final Object obj); int getDegreeOfParallelism(); JsonStream getInput(final int index); List<Operator<?>> getInputOperators(); List<JsonStream> getInputs(); int getMaxInputs(); int getMaxOutputs(); int getMinInputs(); int getMinOutputs(); String getName(); int getNumInputs(); int getNumOutputs(); JsonStream getOutput(final int index); List<JsonStream> getOutputs(); @Override Output getSource(); @Override int hashCode(); @Property @Name(adjective = "parallel") void setDegreeOfParallelism(final int degree); void setInput(final int index, final JsonStream input); void setInputs(final JsonStream... inputs); void setInputs(final List<? extends JsonStream> inputs); void setName(final String name); void validate(); Self withInputs(final JsonStream... inputs); Self withInputs(final List<? extends JsonStream> inputs); Self withName(final String name); final static List<? extends EvaluationExpression> ALL_KEYS; final static int STANDARD_DEGREE_OF_PARALLELISM; }
@Test public void testGetInputs() { final Operator<?> input1 = new OpImpl(0); final Operator<?> input2 = new OpImpl(1); final Operator<?> fixture = new OpImpl(0).withInputs(input1, input2); final List<JsonStream> result = fixture.getInputs(); assertNotNull(result); assertEquals(2, result.size()); final List<JsonStream> expectedResults = new ArrayList<JsonStream>(); expectedResults.add(input1.getOutput(0)); expectedResults.add(input2.getOutput(0)); assertEquals(expectedResults, result); }