flink 3dc7423c4be8c15593a0d3d39cbac883f7c4cb7b

3dc7423c4be8c15593a0d3d39cbac883f7c4cb7b

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 7

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	2
Change Parameter Type value2 : Integer to value2 : Tuple2<Integer,Integer> in method public reduce(value1 Tuple2<Integer,Integer>, value2 Tuple2<Integer,Integer>) : Tuple2<Integer,Integer> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest.FailingFunction	From	To
Change Parameter Type value1 : Integer to value1 : Tuple2<Integer,Integer> in method public reduce(value1 Tuple2<Integer,Integer>, value2 Tuple2<Integer,Integer>) : Tuple2<Integer,Integer> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest.FailingFunction	From	To
Rename Variable	1
Rename Variable num : int to val : Tuple2<Integer,Integer> in method public testSlidingWindow() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Return Type	1
Change Return Type Integer to Tuple2<Integer,Integer> in method public reduce(value1 Tuple2<Integer,Integer>, value2 Tuple2<Integer,Integer>) : Tuple2<Integer,Integer> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest.FailingFunction	From	To
Change Variable Type	22
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public testTumblingWindowDuplicateElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type resultAtSnapshot : List<Integer> to resultAtSnapshot : List<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type result : List<Integer> to result : List<Tuple2<Integer,Integer>> in method public testSlidingWindowSingleElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type result : List<Integer> to result : List<Tuple2<Integer,Integer>> in method public testSlidingWindow() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type result : List<Integer> to result : List<Tuple2<Integer,Integer>> in method public testEmitTrailingDataOnClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type set : HashSet<Integer> to set : HashSet<Tuple2<Integer,Integer>> in method public testTumblingWindowDuplicateElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type result : List<Integer> to result : List<Tuple2<Integer,Integer>> in method public testTumblingWindowDuplicateElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out2 : CollectingOutput<Integer> to out2 : CollectingOutput<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type resultAtSnapshot : List<Integer> to resultAtSnapshot : List<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type result : List<Integer> to result : List<Tuple2<Integer,Integer>> in method public testTumblingWindowUniqueElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type failingFunction : ReduceFunction<Integer> to failingFunction : ReduceFunction<Tuple2<Integer,Integer>> in method public testPropagateExceptionsFromProcessElement() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type num : int to val : Tuple2<Integer,Integer> in method public testSlidingWindow() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public testPropagateExceptionsFromProcessElement() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public testTumblingWindowUniqueElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type finalResult : List<Integer> to finalResult : List<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public testSlidingWindowSingleElements() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public testSlidingWindow() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public testEmitTrailingDataOnClose() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type finalResult : List<Integer> to finalResult : List<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out : CollectingOutput<Integer> to out : CollectingOutput<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Variable Type out2 : CollectingOutput<Integer> to out2 : CollectingOutput<Tuple2<Integer,Integer>> in method public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To
Change Attribute Type	1
Change Attribute Type sumFunction : ReduceFunction<Integer> to sumFunction : ReduceFunction<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest	From	To

3dc7423c4be8c15593a0d3d39cbac883f7c4cb7b

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: