@Test
  public void testClone() {
    OperatorSpecGraph operatorSpecGraph = new OperatorSpecGraph(mockAppDesc);
    OperatorSpecGraph clonedSpecGraph = operatorSpecGraph.clone();
    OperatorSpecTestUtils.assertClonedGraph(operatorSpecGraph, clonedSpecGraph);
  }
Setup two linear transformation pipelines:
1) input1 --> filter --> sendTo
2) input2 --> map --> sink
samza-core/src/test/java/org/apache/samza/operators/TestOperatorSpecGraph.java