|
Change Parameter Type windowFunction : AllWindowFunction<IN,OUT,W> to windowFunction : AllWindowFunction<ACC,OUT,W> in method public EvictingNonKeyedWindowOperator(windowAssigner WindowAssigner<? super IN,W>, windowSerializer TypeSerializer<W>, windowBufferFactory WindowBufferFactory<? super IN,ACC,? extends EvictingWindowBuffer<IN,ACC>>, windowFunction AllWindowFunction<ACC,OUT,W>, trigger Trigger<? super IN,? super W>, evictor Evictor<? super IN,? super W>) in class org.apache.flink.streaming.runtime.operators.windowing.EvictingNonKeyedWindowOperator |
From |
To |
|
Change Parameter Type windowFunction : AllWindowFunction<IN,OUT,W> to windowFunction : AllWindowFunction<ACC,OUT,W> in method public NonKeyedWindowOperator(windowAssigner WindowAssigner<? super IN,W>, windowSerializer TypeSerializer<W>, windowBufferFactory WindowBufferFactory<? super IN,ACC,? extends WindowBuffer<IN,ACC>>, windowFunction AllWindowFunction<ACC,OUT,W>, trigger Trigger<? super IN,? super W>) in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Parameter Type windowBufferFactory : WindowBufferFactory<?,?> to windowBufferFactory : WindowBufferFactory<?,?,?> in method public NonKeyedWindowOperatorTest(windowBufferFactory WindowBufferFactory<?,?,?>) in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperatorTest |
From |
To |
|
Change Parameter Type windowBufferFactory : WindowBufferFactory<? super IN,? extends EvictingWindowBuffer<IN>> to windowBufferFactory : WindowBufferFactory<? super IN,ACC,? extends EvictingWindowBuffer<IN,ACC>> in method public EvictingNonKeyedWindowOperator(windowAssigner WindowAssigner<? super IN,W>, windowSerializer TypeSerializer<W>, windowBufferFactory WindowBufferFactory<? super IN,ACC,? extends EvictingWindowBuffer<IN,ACC>>, windowFunction AllWindowFunction<ACC,OUT,W>, trigger Trigger<? super IN,? super W>, evictor Evictor<? super IN,? super W>) in class org.apache.flink.streaming.runtime.operators.windowing.EvictingNonKeyedWindowOperator |
From |
To |
|
Change Parameter Type windowBuffer : WindowBuffer<IN> to windowBuffer : WindowBuffer<IN,ACC> in method public Context(window W, windowBuffer WindowBuffer<IN,ACC>) in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |
|
Change Parameter Type windowBufferFactory : WindowBufferFactory<? super IN,? extends WindowBuffer<IN>> to windowBufferFactory : WindowBufferFactory<? super IN,ACC,? extends WindowBuffer<IN,ACC>> in method public NonKeyedWindowOperator(windowAssigner WindowAssigner<? super IN,W>, windowSerializer TypeSerializer<W>, windowBufferFactory WindowBufferFactory<? super IN,ACC,? extends WindowBuffer<IN,ACC>>, windowFunction AllWindowFunction<ACC,OUT,W>, trigger Trigger<? super IN,? super W>) in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,TimeWindow> to operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,Tuple2<String,Integer>,TimeWindow> in method public testSlidingEventTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperatorTest |
From |
To |
|
Change Variable Type operator : NonKeyedWindowOperator<T,R,W> to operator : NonKeyedWindowOperator<T,T,R,W> in method public apply(function AllWindowFunction<T,R,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Variable Type windowBuffer : WindowBuffer<IN> to windowBuffer : WindowBuffer<IN,ACC> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,GlobalWindow> to operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,Tuple2<String,Integer>,GlobalWindow> in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperatorTest |
From |
To |
|
Change Variable Type operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,GlobalWindow> to operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,Tuple2<String,Integer>,GlobalWindow> in method public testContinuousWatermarkTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperatorTest |
From |
To |
|
Change Variable Type operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,TimeWindow> to operator : NonKeyedWindowOperator<Tuple2<String,Integer>,Tuple2<String,Integer>,Tuple2<String,Integer>,TimeWindow> in method public testTumblingEventTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperatorTest |
From |
To |
|
Change Variable Type windowBuffer : EvictingWindowBuffer<IN> to windowBuffer : EvictingWindowBuffer<IN,ACC> in method protected emitWindow(context Context) : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingNonKeyedWindowOperator |
From |
To |