@Test public void processorMulti() { final PCollection<SampleLength> out = pipeline .apply(Create.of(new Sample("a"), new Sample("bb")).withCoder(JsonbCoder.of(Sample.class, PLUGIN))) .apply(UUID.randomUUID().toString(), toRecord()) .setCoder(SchemaRegistryCoder.of()) .apply(new ViewsMappingTransform(emptyMap(), PLUGIN)) .apply(TalendFn.asFn(new BaseTestProcessor() { @Override public void onNext(final InputFactory input, final OutputFactory factory) { final Object read = input.read(Branches.DEFAULT_BRANCH); factory .create(Branches.DEFAULT_BRANCH) .emit(new Sample(Record.class.cast(read).getString("data"))); } })) .apply(toSampleLength()); PAssert.that(out.apply(UUID.randomUUID().toString(), toInt())).containsInAnyOrder(1, 2); assertEquals(PipelineResult.State.DONE, pipeline.run().getState()); }
public static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper) { return read(mapper, emptyMap()); }
TalendIO { public static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper) { return read(mapper, emptyMap()); } }
TalendIO { public static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper) { return read(mapper, emptyMap()); }  }
TalendIO { public static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper) { return read(mapper, emptyMap()); }  static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper); static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper,
            final Map<String, String> mapperConfiguration); static Write write(final Processor output); }
TalendIO { public static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper) { return read(mapper, emptyMap()); }  static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper); static Base<PBegin, PCollection<Record>, Mapper> read(final Mapper mapper,
            final Map<String, String> mapperConfiguration); static Write write(final Processor output);  }