@Test
public void testUnique() throws Exception {

  CascadingHelper.get().getFlowConnector().connect(Tests.getInTap(), Tests.getOutTap(), Pump.prime().retain("line").unique("line").toPipe()).complete();
  assertEquals(Arrays.asList("0", "115200000", "asdf"), getOutputStrings());
}