|
Change Parameter Type function : Function to function : ReduceFunction<?> in method private createFastTimeOperatorIfValid(function ReduceFunction<?>, resultType TypeInformation<R>, functionName String) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Parameter Type window : TimeWindow to context : Context in method public process(key Integer, context Context, values Iterable<Integer>, out Collector<Integer>) : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest.StatefulFunction |
From |
To |
|
Change Parameter Type function : WindowFunction<Type,Result,Key,Window> to function : InternalWindowFunction<Iterable<Type>,Result,Key,Window> in method public AccumulatingKeyedTimePanes(keySelector KeySelector<Type,Key>, function InternalWindowFunction<Iterable<Type>,Result,Key,Window>) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes |
From |
To |
|
Change Parameter Type function : WindowFunction<Type,Result,Key,Window> to function : InternalWindowFunction<Iterable<Type>,Result,Key,Window> in method package WindowFunctionTraversal(function InternalWindowFunction<Iterable<Type>,Result,Key,Window>, window TimeWindow, out Collector<Result>, contextOperator AbstractStreamOperator<Result>) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes.WindowFunctionTraversal |
From |
To |
|
Change Parameter Type function : WindowFunction<IN,OUT,KEY,TimeWindow> to function : InternalWindowFunction<Iterable<IN>,OUT,KEY,TimeWindow> in method public AccumulatingProcessingTimeWindowOperator(function InternalWindowFunction<Iterable<IN>,OUT,KEY,TimeWindow>, keySelector KeySelector<IN,KEY>, keySerializer TypeSerializer<KEY>, valueSerializer TypeSerializer<IN>, windowLength long, windowSlide long) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator |
From |
To |
|
Change Attribute Type mockFunction : WindowFunction<String,String,String,TimeWindow> to mockFunction : InternalIterableWindowFunction<String,String,String,TimeWindow> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Attribute Type validatingIdentityFunction : WindowFunction<Integer,Integer,Integer,TimeWindow> to validatingIdentityFunction : InternalIterableWindowFunction<Integer,Integer,Integer,TimeWindow> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Attribute Type function : WindowFunction<Type,Result,Key,Window> to function : InternalWindowFunction<Iterable<Type>,Result,Key,Window> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes |
From |
To |
|
Change Attribute Type function : WindowFunction<Type,Result,Key,Window> to function : InternalWindowFunction<Iterable<Type>,Result,Key,Window> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingKeyedTimePanes.WindowFunctionTraversal |
From |
To |