@Test public void inputInfinite() { final PCollection<Record> out = pipeline.apply(TalendIO.read(new TheTestMapper() { @Override public boolean isStream() { return true; } @Override public Input create() { return new BaseTestInput() { private transient Iterator<String> chain; @Override public Object next() { if (chain == null) { chain = asList("a", "b").iterator(); } return chain.hasNext() ? new Sample(chain.next()) : null; } }; } @Override public int hashCode() { return 0; } @Override public boolean equals(final Object obj) { return getClass().isInstance(obj); } }, singletonMap("maxRecords", "1"))); PAssert.that(out.apply(UUID.randomUUID().toString(), ParDo.of(new DoFn<Record, String>() { @ProcessElement public void toData(final ProcessContext sample) { sample.output(sample.element().getString("data")); } }))).containsInAnyOrder("a"); 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);  }