.keyField(LongValue.class, 0, 0)
.name("CoGroup").input1(source1).input2(source2).build();
Ordering groupOrder1 = new Ordering(5, StringValue.class, Order.DESCENDING);
Ordering groupOrder2 = new Ordering(1, StringValue.class, Order.DESCENDING);
groupOrder2.appendOrdering(4, DoubleValue.class, Order.ASCENDING);
coGroup.setGroupOrderForInputOne(groupOrder1);
coGroup.setGroupOrderForInputTwo(groupOrder2);
FileDataSink sink = new FileDataSink(new DummyOutputFormat(), OUT_FILE, coGroup, "Sink");