Extrude extends BaseOperation implements Function { public Extrude(String outputField) { super(new Fields(outputField)); } Extrude(String outputField); @Override void operate(FlowProcess flowProcess, FunctionCall functionCall);  }
@Test public void testExtrude() { List<Tuple> results = TestHelpers.exec( new Extrude("output"), new Fields("first", "second"), new Tuple("first", "second")); assertEquals(2, results.size()); assertEquals(Arrays.asList(new Tuple("first"), new Tuple("second")), results); }