Operator extends ConfigurableSopremoType implements
		ISopremoType, JsonStream, Cloneable { @Override public Output getSource() { return (Output) this.getOutput(0); } 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 testGetSource() { final Operator<?> fixture = new OpImpl(0); final JsonStream result = fixture.getSource(); assertNotNull(result); assertEquals(0, result.getSource().getIndex()); assertSame(fixture.getOutput(0), result); }