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