flink 01c74338ff44ea7f3735a7eb94b2ce01ababc505

01c74338ff44ea7f3735a7eb94b2ce01ababc505

Files Diff

Added: 6
Removed: 0
Renamed: 0
Modified: 5

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	2
	Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Integer,Integer>> in method public combine(records Iterable<Tuple2<Integer,Integer>>, out Collector<Tuple2<Integer,Integer>>) : void in class org.apache.flink.runtime.operators.CombineTaskTest.MockCombiningReduceStub	From	To
	Change Parameter Type records : Iterable<Record> to records : Iterable<Tuple2<Integer,Integer>> in method public combine(records Iterable<Tuple2<Integer,Integer>>, out Collector<Tuple2<Integer,Integer>>) : void in class org.apache.flink.runtime.operators.CombineTaskTest.MockCombiningReduceStub	From	To
	Move Method	3
	Move Method public reduce(records Iterable<Record>, out Collector<Record>) : void from class org.apache.flink.runtime.operators.CombineTaskTest.MockFailingCombiningReduceStub to public reduce(records Iterable<Record>, out Collector<Record>) : void from class org.apache.flink.runtime.operators.CombineTaskExternalITCase.MockFailingCombiningReduceStub	From	To
	Move Method public reduce(records Iterable<Record>, out Collector<Record>) : void from class org.apache.flink.runtime.operators.CombineTaskTest.MockCombiningReduceStub to public reduce(records Iterable<Record>, out Collector<Record>) : void from class org.apache.flink.runtime.operators.CombineTaskExternalITCase.MockCombiningReduceStub	From	To
	Move Method public combine(records Iterable<Record>, out Collector<Record>) : void from class org.apache.flink.runtime.operators.CombineTaskTest.MockFailingCombiningReduceStub to public combine(records Iterable<Record>, out Collector<Record>) : void from class org.apache.flink.runtime.operators.CombineTaskExternalITCase.MockFailingCombiningReduceStub	From	To
	Extract Superclass	1
	Extract Superclass org.apache.flink.runtime.operators.testutils.UnaryOperatorTestBase from classes [org.apache.flink.runtime.operators.CombineTaskTest]	From	To
	Change Variable Type	4
	Change Variable Type sb : StringBuffer to sb : StringBuilder in method private randomString() : String in class org.apache.flink.runtime.operators.testutils.TestData.Generator	From	To
	Change Variable Type testTask : GroupReduceCombineDriver<Record,Record> to testTask : GroupReduceCombineDriver<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testCombineTask() : void in class org.apache.flink.runtime.operators.CombineTaskTest	From	To
	Change Variable Type testTask : GroupReduceCombineDriver<Record,Record> to testTask : GroupReduceCombineDriver<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testFailingCombineTask() : void in class org.apache.flink.runtime.operators.CombineTaskTest	From	To
	Change Variable Type testTask : GroupReduceCombineDriver<Record,Record> to testTask : GroupReduceCombineDriver<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testCancelCombineTaskSorting() : void in class org.apache.flink.runtime.operators.CombineTaskTest	From	To
	Change Attribute Type	2
	Change Attribute Type outList : ArrayList<Record> to outList : ArrayList<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.CombineTaskTest	From	To
	Change Attribute Type comparator : RecordComparator to comparator : TypeComparator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.CombineTaskTest	From	To