You may find GenerateSequence can serve your needs: https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/io/GenerateSequence.java
On Wed, Sep 6, 2017 at 2:18 PM, Thomas Weise <[email protected]> wrote: > Hi Eugene, > > TestStream is great for functional testing. I was looking for a way to > continuously generate data instead of specifying it upfront as collection, > hence my question regarding the UnboundedSource hierarchy. > > Thomas > > > On Tue, Sep 5, 2017 at 10:09 AM, Eugene Kirpichov < > [email protected]> wrote: > > > Hi, did you look at TestStream? > > > > On Tue, Sep 5, 2017, 9:37 AM Thomas Weise <[email protected]> wrote: > > > > > Hi, > > > > > > I'm looking for the suitable starting point to create an unbounded > source > > > for testing of a pipeline. The source should generate data (let's say > > > KV<String, Integer>), but can also inject watermarks. > > > > > > I see couple implementations like TestCountingSource used for runner > > > testing, is the starting point for users UnboundedSource? > > > > > > Thanks, > > > Thomas > > > > > >
