; predictable, and that elements from main stream arrive after elements from
> control stream, or other way around.
>
>
>
> Thanks again,
>
> Tovi
>
>
>
> *From:* Kostas Kloudas [mailto:k.klou...@data-artisans.com]
> *Sent:* יום ה 07 דצמבר 2017 19:11
> *To:
@flink.apache.org
Subject: Re: Testing CoFlatMap correctness
Hi Tovi,
What you need is the TwoInputStreamOperatorTestHarness. This will allow you to
do something like:
TwoInputStreamOperatorTestHarness testHarness =
new TwoInputStreamOperatorTestHarness<>(myoperator);
testHarness
Hi Tovi,
What you need is the TwoInputStreamOperatorTestHarness. This will allow you to
do something like:
TwoInputStreamOperatorTestHarness testHarness =
new TwoInputStreamOperatorTestHarness<>(myoperator);
testHarness.setup();
testHarness.open();
testHarness.processWatermark1(new Water
