: Timo Walther
Dato: fredag, 17. desember 2021 kl. 14:20
Til: user@flink.apache.org
Emne: Re: Svar: WindowOperator TestHarness
Hi Pierre,
sorry, for the late reply.
The `getTransformation` might only be available in the Java DataStream
API. The Scala `DataStream` object is only a think wrapper
Hi Pierre,
sorry, for the late reply.
The `getTransformation` might only be available in the Java DataStream
API. The Scala `DataStream` object is only a think wrapper around the
Java one. You can access the origin via:
dataStream.javaStream.getTransformation()
I hope this helps.
Regards,
Hi Timo,
And thank you for the detailed answer.
We chose to go for the second alternative using the following:
import org.apache.flink.streaming.api.transformations.OneInputTransformation
import
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
val env = StreamExecutionE
