|
Change Parameter Type function : KeyedWindowFunction<Type,Result,Key> to function : KeyedWindowFunction<Type,Result,Key,Window> in method package WindowFunctionTraversal(function KeyedWindowFunction<Type,Result,Key,Window>, window TimeWindow, out Collector<Result>) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes.WindowFunctionTraversal |
From |
To |
|
Change Parameter Type function : KeyedWindowFunction<IN,OUT,KEY> to function : KeyedWindowFunction<IN,OUT,KEY,Window> in method public AccumulatingProcessingTimeWindowOperator(function KeyedWindowFunction<IN,OUT,KEY,Window>, keySelector KeySelector<IN,KEY>, windowLength long, windowSlide long) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator |
From |
To |
|
Change Parameter Type function : KeyedWindowFunction<Type,Result,Key> to function : KeyedWindowFunction<Type,Result,Key,Window> in method public AccumulatingKeyedTimePanes(keySelector KeySelector<Type,Key>, function KeyedWindowFunction<Type,Result,Key,Window>) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes |
From |
To |
|
Change Parameter Type function : KeyedWindowFunction<T,Result,K> to function : KeyedWindowFunction<T,Result,K,Window> in method public mapWindow(function KeyedWindowFunction<T,Result,K,Window>) : DataStream<Result> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |
|
Change Variable Type windowFunction : KeyedWindowFunction<IN,OUT,KEY> to windowFunction : KeyedWindowFunction<IN,OUT,KEY,Window> in method protected createPanes(keySelector KeySelector<IN,KEY>, function Function) : AccumulatingKeyedTimePanes<IN,KEY,OUT> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator |
From |
To |
|
Change Variable Type wf : KeyedWindowFunction<IN,OUT,KEY> to wf : KeyedWindowFunction<IN,OUT,KEY,Window> in method public createOperatorForPolicies(window WindowPolicy, slide WindowPolicy, function Function, keySelector KeySelector<IN,KEY>) : OneInputStreamOperator<IN,OUT> in class org.apache.flink.streaming.runtime.operators.windowing.PolicyToOperator |
From |
To |
|
Change Variable Type failingFunction : KeyedWindowFunction<Integer,Integer,Integer> to failingFunction : KeyedWindowFunction<Integer,Integer,Integer,Window> in method public testPropagateExceptionsFromClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Attribute Type function : KeyedWindowFunction<Type,Result,Key> to function : KeyedWindowFunction<Type,Result,Key,Window> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes.WindowFunctionTraversal |
From |
To |
|
Change Attribute Type function : KeyedWindowFunction<Type,Result,Key> to function : KeyedWindowFunction<Type,Result,Key,Window> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes |
From |
To |
|
Change Attribute Type validatingIdentityFunction : KeyedWindowFunction<Integer,Integer,Integer> to validatingIdentityFunction : KeyedWindowFunction<Integer,Integer,Integer,Window> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Attribute Type mockFunction : KeyedWindowFunction<String,String,String> to mockFunction : KeyedWindowFunction<String,String,String,Window> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |