@Test public void boundedReadTest() { List<String> inputList = asList( "one", "two", "three", "four", "five", "one two three four four two two", "one one one two two three"); ListDataSource<String> input = ListDataSource.bounded(inputList); PCollection<String> output = testPipeline.apply(EuphoriaIO.read(input, StringUtf8Coder.of())); PAssert.that(output).containsInAnyOrder(inputList); testPipeline.run().waitUntilFinish(); }
public static <T> Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder) { return new Read<>(dataSource, outputCoder); }
EuphoriaIO { public static <T> Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder) { return new Read<>(dataSource, outputCoder); } }
EuphoriaIO { public static <T> Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder) { return new Read<>(dataSource, outputCoder); }  }
EuphoriaIO { public static <T> Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder) { return new Read<>(dataSource, outputCoder); }  static Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder); }
EuphoriaIO { public static <T> Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder) { return new Read<>(dataSource, outputCoder); }  static Read<T> read(DataSource<T> dataSource, Coder<T> outputCoder);  }