Re: Generating data stream for testing

[Eugene Kirpichov]

Hi, did you look at TestStream?

On Tue, Sep 5, 2017, 9:37 AM Thomas Weise <t...@apache.org> 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
>