Hi Ken,
you can use the (slightly misnamed for this purpose)
AbstractStreamOperatorTestHarness. It's used in the Flink codebase for unit
testing sources.
Best,
Aljoscha
> On 12. Sep 2018, at 23:37, Ken Krugler wrote:
>
> Hi all,
>
> We’re using the (Keyed)(One|Two)InputStreamOperatorTestHar
Hi all,
We’re using the (Keyed)(One|Two)InputStreamOperatorTestHarness classes to test
checkpointing of some custom functions.
But in looking through the Flink source, I didn’t see anything comparable for
testing a custom SourceFunction (which implements the ListCheckpointed
interface).
What’
