Re: Testing CoFlatMap correctness

ה 07 דצמבר 2017 19:11 > *To:* Sofer, Tovi [ICG-IT] <ts72...@imceu.eu.ssmb.com> > *Cc:* user@flink.apache.org > *Subject:* Re: Testing CoFlatMap correctness > > > > Hi Tovi, > > > > What you need is the TwoInputStreamOperatorTestHarness. This w

RE: Testing CoFlatMap correctness

s72...@imceu.eu.ssmb.com> Cc: user@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<Integer, String, String> testHarness

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.setup(); testHarness.open();