Svar: Svar: WindowOperator TestHarness

2021-12-17 Thread Pierre Bedoucha
: 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

Re: Svar: WindowOperator TestHarness

2021-12-17 Thread Timo Walther
her *Dato: *mandag, 13. desember 2021 kl. 08:53 *Til: *user@flink.apache.org *Emne: *Re: WindowOperator TestHarness Hi Lars, you can take a look at how org.apache.flink.streaming.api.datastream.WindowedStream#WindowedStream constructs the graph under the hood. In particular, it u

Svar: WindowOperator TestHarness

2021-12-16 Thread Pierre Bedoucha
org Emne: Re: WindowOperator TestHarness Hi Lars, you can take a look at how org.apache.flink.streaming.api.datastream.WindowedStream#WindowedStream constructs the graph under the hood. In particular, it uses org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder which constructs

Re: WindowOperator TestHarness

2021-12-12 Thread Timo Walther
Hi Lars, you can take a look at how org.apache.flink.streaming.api.datastream.WindowedStream#WindowedStream constructs the graph under the hood. In particular, it uses org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder which constructs the InternalWindowFunction you

WindowOperator TestHarness

2021-12-10 Thread Lars Skjærven
Hello, We're trying to write a test for an implementation of *AggregateFunction* following a *EventTimeSessionWindows.withGap*. We gave it a try using *WindowOperator*() which we hoped could be used as an argument to *KeyedOneInputStreamOperatorTestHarness*. We're a bit stuck, and we're hoping som