erWithClientResource in order to use
> StreamExecutionEnvironment?
>
>
>
>
>
> Best,
>
> Michael
>
>
>
>
>
> *From: *vino yang
> *Date: *Monday, October 28, 2019 at 1:32 AM
> *To: *Michael Nguyen
> *Cc: *"user@flink.apache.org"
> *Subjec
From: vino yang
Date: Monday, October 28, 2019 at 1:32 AM
To: Michael Nguyen
Cc: "user@flink.apache.org"
Subject: Re: Testing AggregateFunction() and ProcessWindowFunction() on
KeyedDataStream
[External]
Hi Michael,
You may need to know `KeyedOneInputStreamOperatorTestHarness`
Hi Michael,
You may need to know `KeyedOneInputStreamOperatorTestHarness` test class.
You can consider
`WindowTranslationTest#testAggregateWithWindowFunctionEventTime` or
`WindowTranslationTest#testAggregateWithWindowFunctionProcessingTime`[1](both
of them call `processElementAndEnsureOutput`) as
