flink c24dca501e1b0e1dcdc38d2e81e0a182bc2ae6bb

c24dca501e1b0e1dcdc38d2e81e0a182bc2ae6bb

Files Diff

Added: 2
Removed: 0
Renamed: 0
Modified: 25

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	1
Change Parameter Type partitioner : KeySelector<?,Serializable> to partitioner : KeySelector<?,?> in method public setStatePartitioner(partitioner KeySelector<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig	From	To
Change Return Type	1
Change Return Type AbstractKeyedTimePanes<IN,KEY,?,OUT> to AbstractKeyedTimePanes<IN,KEY,STATE,OUT> in method protected abstract createPanes(keySelector KeySelector<IN,KEY>, function Function) : AbstractKeyedTimePanes<IN,KEY,STATE,OUT> in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator	From	To
Change Variable Type	12
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> to op : AccumulatingProcessingTimeWindowOperator<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<String,String,String,?> to op : AccumulatingProcessingTimeWindowOperator<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 : AccumulatingProcessingTimeWindowOperator<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<Integer,Integer,Integer,?> to op : AccumulatingProcessingTimeWindowOperator<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<String,String,String,?> to op : AccumulatingProcessingTimeWindowOperator<String,String,String> in method public testWindowTriggerTimeAlignment() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type keySelector : KeySelector<Tuple2<Integer,Integer>,?> to keySelector : KeySelector<Tuple2<Integer,Integer>,Tuple> in method public groupSumIntegerTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest	From	To
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> to op : AccumulatingProcessingTimeWindowOperator<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<Integer,Integer,Integer,?> to op : AccumulatingProcessingTimeWindowOperator<Integer,Integer,Integer> in method public testEmitTrailingDataOnClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type keySelector : KeySelector<Tuple3<Integer,Integer,Integer>,?> to keySelector : KeySelector<Tuple3<Integer,Integer,Integer>,Tuple> in method public minMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest	From	To
Change Variable Type keySelector : KeySelector<MyPojo3,?> to keySelector : KeySelector<MyPojo3,Tuple> in method public pojoMinMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest	From	To
Change Variable Type op : AbstractAlignedProcessingTimeWindowOperator<Integer,Integer,Integer,?> to op : AccumulatingProcessingTimeWindowOperator<Integer,Integer,Integer> in method public testPropagateExceptionsFromClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type keySelector : KeySelector<MyPojo,?> to keySelector : KeySelector<MyPojo,Tuple> in method public pojoGroupSumIntegerTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest	From	To
Extract Variable	3
Extract Variable firstTriggerTime : long in method public open() : void from class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator	From	To
Extract Variable record : StreamRecord<IN> in method public createAndExecuteForKeyedStream(operator OneInputStreamOperator<IN,OUT>, inputs List<IN>, keySelector KeySelector<IN,KEY>, keyType TypeInformation<KEY>) : List<OUT> from class org.apache.flink.streaming.util.MockContext	From	To
Extract Variable config : StreamConfig in method public createAndExecuteForKeyedStream(operator OneInputStreamOperator<IN,OUT>, inputs List<IN>, keySelector KeySelector<IN,KEY>, keyType TypeInformation<KEY>) : List<OUT> from class org.apache.flink.streaming.util.MockContext	From	To
Extract Method	1
Extract Method public createAndExecuteForKeyedStream(operator OneInputStreamOperator<IN,OUT>, inputs List<IN>, keySelector KeySelector<IN,KEY>, keyType TypeInformation<KEY>) : List<OUT> extracted from public createAndExecute(operator OneInputStreamOperator<IN,OUT>, inputs List<IN>) : List<OUT> in class org.apache.flink.streaming.util.MockContext	From	To
Change Attribute Type	1
Change Attribute Type panes : AbstractKeyedTimePanes<IN,KEY,?,OUT> to panes : AbstractKeyedTimePanes<IN,KEY,STATE,OUT> in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator	From	To

c24dca501e1b0e1dcdc38d2e81e0a182bc2ae6bb

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: