Pump { public Pump discard(String ... fieldsToDiscard) { return new PipeAdapterPump(this, new Discard(toPipe(), getArgSelector(fieldsToDiscard))); }  Set<Class> getEmittedClasses(); final Pipe toPipe(); static Pump prime(); static Pump prime(String pipeName); static Pump prime(Pipe pipe); CoGroupPump cogroup(Pump other, String... cogroupFields); CoGroupPump cogroup(Pump other, Joiner joiner, String... cogroupFields); static CoGroupPump cogroup(Pump left, Pump right, String... cogroupFields); static CoGroupPump cogroup(Pump left, Pump right, Joiner joiner, String... cogroupFields); Pump each(Function function, String... args); Pump each(Filter filter, String... args); Pump failOnNull(String errorText, String... args); Pump unique(String... uniqueFields); GroupByPump groupby(String... fields); Pump aggregateby(AggregateBy.Functor functor, Aggregator aggregator, String... args); Pump average(String valueField, String averageField); Pump count(String countField); Pump first(String... firstFields); Pump sum(String valueField, String sumField); AggregatorPump every(Aggregator agg, String... args); Pump every(Buffer buffer, String... args); Pump retain(String ... fieldsToKeep); Pump discard(String ... fieldsToDiscard); Pump coerce(String field, Class toClass); Pump coerce(Class toClass, String... fieldsToCoerce); Pump coerce(String[] fields, Class<?>[] classes); Pump rename(String field, String toName); Pump replace(String field, String toName); Pump getOrElse(String fromField, String toField, Tuple value); Pump branch();  }
@Test public void testDiscard() throws IOException { Pipe p = Pump.prime() .discard("offset") .toPipe(); CascadingHelper.get().getFlowConnector().connect(Tests.getInTap(), Tests.getOutTap(), p).complete(); assertEquals(Arrays.asList("115200000", "0", "115200000", "asdf"), getOutputStrings()); }