|
Change Parameter Type function : KeyedWindowFunction<IN,OUT,KEY,Window> to function : KeyedWindowFunction<IN,OUT,KEY,TimeWindow> in method public AccumulatingProcessingTimeWindowOperator(function KeyedWindowFunction<IN,OUT,KEY,TimeWindow>, keySelector KeySelector<IN,KEY>, windowLength long, windowSlide long) in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator |
From |
To |
|
Change Parameter Type window : Window to window : TimeWindow in method public evaluate(integer Integer, window TimeWindow, values Iterable<Integer>, out Collector<Integer>) : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest.FailingFunction |
From |
To |
|
Change Parameter Type function : Function to function : F in method protected AbstractAlignedProcessingTimeWindowOperator(function F, keySelector KeySelector<IN,KEY>, windowLength long, windowSlide long) in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer> to op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> in method public testPropagateExceptionsFromClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer> to op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> in method public testSlidingWindow() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<String,String,String> to op : AggregatingProcessingTimeWindowOperator<String,String> in method public testWindowSizeAndSlide() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer> to op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> in method public testTumblingWindowSingleElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer> to op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> in method public testEmitTrailingDataOnClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type failingFunction : KeyedWindowFunction<Integer,Integer,Integer,Window> to failingFunction : KeyedWindowFunction<Integer,Integer,Integer,TimeWindow> in method public testPropagateExceptionsFromClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<String,String,String> to op : AbstractAlignedProcessingTimeWindowOperator<String,String,String,?> in method public testWindowSizeAndSlide() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer> to op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> in method public testSlidingWindowSingleElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer> to op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> in method public testTumblingWindow() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<String,String,String> to op : AbstractAlignedProcessingTimeWindowOperator<String,String,String,?> in method public testWindowTriggerTimeAlignment() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<String,String,String> to op : AggregatingProcessingTimeWindowOperator<String,String> in method public testWindowTriggerTimeAlignment() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type wf : KeyedWindowFunction<T,R,K,Window> to wf : KeyedWindowFunction<T,R,K,TimeWindow> in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : DataStream<R> in class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream |
From |
To |