Re: Question about unbounded in-memory PCollection

Hi Rui, Thanks for your reply. This is what I want!! For TestStream.java [1], my understanding is I can attach an event time to my record and let watermark advance to get unbounded

Re: Question about unbounded in-memory PCollection

Does 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,

Re: Question about unbounded in-memory PCollection

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 unb