flink 5914e9ab3fa8e8be8fff9d7e6c10d612af7e27cf

5914e9ab3fa8e8be8fff9d7e6c10d612af7e27cf

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 27

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Push Down Method	2
	Push Down Method public combine(values Iterable<IN>, out Collector<IN>) : void from class org.apache.flink.api.common.functions.RichGroupReduceFunction to public combine(records Iterable<T>, out Collector<T>) : void from class org.apache.flink.api.scala.operators.ScalaAggregateOperator.AggregatingUdf	From	To
	Push Down Method public combine(values Iterable<IN>, out Collector<IN>) : void from class org.apache.flink.api.common.functions.RichGroupReduceFunction to public combine(records Iterable<T>, out Collector<T>) : void from class org.apache.flink.api.java.operators.AggregateOperator.AggregatingUdf	From	To
	Change Parameter Type	6
	Change Parameter Type out : Collector<IN> to out : Collector<T> in method public combine(records Iterable<T>, out Collector<T>) : void in class org.apache.flink.api.java.operators.AggregateOperator.AggregatingUdf	From	To
	Change Parameter Type out : Collector<IN> to out : Collector<T> in method public combine(records Iterable<T>, out Collector<T>) : void in class org.apache.flink.api.scala.operators.ScalaAggregateOperator.AggregatingUdf	From	To
	Change Parameter Type function : RichGroupReduceFunction<IN,OUT> to function : GroupReduceFunction<IN,OUT> in method private translateSelectorFunctionDistinct(rawKeys SelectorFunctionKeys<IN,?>, function GroupReduceFunction<IN,OUT>, outputType TypeInformation<OUT>, name String, input Operator<IN>) : PlanUnwrappingReduceGroupOperator<IN,OUT,K> in class org.apache.flink.api.java.operators.DistinctOperator	From	To
	Change Parameter Type values : Iterable<IN> to values : Iterable<T> in method public combine(values Iterable<T>, out Collector<T>) : void in class org.apache.flink.optimizer.testfunctions.IdentityGroupReducerCombinable	From	To
	Change Parameter Type out : Collector<IN> to out : Collector<T> in method public combine(values Iterable<T>, out Collector<T>) : void in class org.apache.flink.optimizer.testfunctions.IdentityGroupReducerCombinable	From	To
	Change Parameter Type wrapped : RichGroupReduceFunction<IN,OUT> to wrapped : GroupReduceFunction<IN,OUT> in method private TupleUnwrappingGroupCombinableGroupReducer(wrapped GroupReduceFunction<IN,OUT>) in class org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer	From	To
	Move Method	1
	Move Method public combine(values Iterable<IN>, out Collector<IN>) : void from class org.apache.flink.api.common.functions.RichGroupReduceFunction to public combine(values Iterable<T>, out Collector<T>) : void from class org.apache.flink.optimizer.testfunctions.IdentityGroupReducerCombinable	From	To
	Change Variable Type	3
	Change Variable Type function : RichGroupReduceFunction<T,T> to function : GroupReduceFunction<T,T> in method protected translateToDataFlow(input Operator<T>) : GroupReduceOperatorBase<?,T,?> in class org.apache.flink.api.java.operators.DistinctOperator	From	To
	Change Variable Type centersSource : GenericDataSourceBase to centersSource : GenericDataSourceBase<?,?> in method public testCompileKMeansSingleStepWithStats() : void in class org.apache.flink.test.optimizer.examples.KMeansSingleStepTest	From	To
	Change Variable Type pointsSource : GenericDataSourceBase to pointsSource : GenericDataSourceBase<?,?> in method public testCompileKMeansSingleStepWithStats() : void in class org.apache.flink.test.optimizer.examples.KMeansSingleStepTest	From	To