Does TestStream.java <https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java>[1] satisfy your need?
-Rui [1] https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java On Tue, May 7, 2019 at 2:47 PM Chengzhi Zhao <w.zhaocheng...@gmail.com> wrote: > Hi Beam Team, > > I am new to here and recently study the programming guide, I have a > question about the in-memory data, > https://beam.apache.org/documentation/programming-guide/#creating-a-pcollection > > Is there a way to create unbounded PCollection from the in-memory > collection? I want to test the unbounded PCollection locally and don't know > what's the easiest way to get unbounded PCollection. Please let me know if > I am doing something wrong or I should use a file system to do it. > > Thanks in advance! > > Best, > Chengzhi > > On Tue, May 7, 2019 at 5:46 PM Chengzhi Zhao <w.zhaocheng...@gmail.com> > wrote: > >> Hi Beam Team, >> >> I am new to here and recently study the programming guide, I have a >> question about the in-memory data, >> https://beam.apache.org/documentation/programming-guide/#creating-a-pcollection >> >> Is there a way to create unbounded PCollection from the in-memory >> collection? I want to test the unbounded PCollection locally and don't know >> what's the easiest way to get unbounded PCollection. Please let me know if >> I am doing something wrong or I should use a file system to do it. >> >> Thanks in advance! >> >> Best, >> Chengzhi >> >
