@Override
    public ScheduledFunction getScheduledFn() {
      return null;
    }
Setup two linear transformation pipelines:
1) input1 --> filter --> sendTo
2) input2 --> map --> sink
samza-core/src/test/java/org/apache/samza/operators/TestOperatorSpecGraph.java