|
Change Variable Type operator : OneInputStreamOperator<T,R> to operator : WindowOperator<K,T,R,W> in method public apply(function WindowFunction<T,R,K,W>, resultType TypeInformation<R>) : DataStream<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Variable Type timeWindows : TumblingProcessingTimeWindows to timeWindows : TumblingTimeWindows in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : DataStream<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Variable Type timeWindows : SlidingProcessingTimeWindows to timeWindows : SlidingTimeWindows in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : DataStream<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Variable Type operator : OneInputStreamOperator<T,R> to operator : NonKeyedWindowOperator<T,R,W> in method public apply(function AllWindowFunction<T,R,W>, resultType TypeInformation<R>) : DataStream<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |