Pump { public Pump coerce(String field, Class toClass) { return coerce(toClass, field); }  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 testCoerce() throws Exception { Pipe p = Pump.prime() .discard("offset") .each(new RegexFilter("^[0-9]+$", false), "line") .coerce("line", long.class) .toPipe(); CascadingHelper.get().getFlowConnector().connect(Tests.getInTap(), Tests.getOutTap(), p).complete(); assertEquals(Arrays.asList("115200000", "0", "115200000"), getOutputStrings()); }