flink 1542260d52238e87de4fa040e6079465777e8263

1542260d52238e87de4fa040e6079465777e8263

Files Diff

Added: 1
Removed: 0
Renamed: 0
Modified: 11

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	8
	Change Parameter Type aggregateFunction : AggregateFunction<T,ACC,R> to aggregateFunction : AggregateFunction<T,ACC,V> in method public aggregate(aggregateFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>, accumulatorType TypeInformation<ACC>, aggregateResultType TypeInformation<V>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
	Change Parameter Type windowFunction : WindowFunction<R,R,K,W> to windowFunction : WindowFunction<V,R,K,W> in method public aggregate(aggFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
	Change Parameter Type aggFunction : AggregateFunction<T,ACC,R> to aggFunction : AggregateFunction<T,ACC,V> in method public AggregateApplyAllWindowFunction(aggFunction AggregateFunction<T,ACC,V>, windowFunction AllWindowFunction<V,R,W>) in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction	From	To
	Change Parameter Type aggFunction : AggregateFunction<T,ACC,R> to aggFunction : AggregateFunction<T,ACC,V> in method public aggregate(aggFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
	Change Parameter Type windowFunction : WindowFunction<R,R,K,W> to windowFunction : WindowFunction<V,R,K,W> in method public AggregateApplyWindowFunction(aggFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>) in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction	From	To
	Change Parameter Type aggFunction : AggregateFunction<T,ACC,R> to aggFunction : AggregateFunction<T,ACC,V> in method public AggregateApplyWindowFunction(aggFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>) in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction	From	To
	Change Parameter Type windowFunction : WindowFunction<R,R,K,W> to windowFunction : WindowFunction<V,R,K,W> in method public aggregate(aggregateFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>, accumulatorType TypeInformation<ACC>, aggregateResultType TypeInformation<V>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
	Change Parameter Type windowFunction : AllWindowFunction<R,R,W> to windowFunction : AllWindowFunction<V,R,W> in method public AggregateApplyAllWindowFunction(aggFunction AggregateFunction<T,ACC,V>, windowFunction AllWindowFunction<V,R,W>) in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction	From	To
	Move Attribute	2
	Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest.DummyReducer to private serialVersionUID : long from class org.apache.flink.api.common.functions.RichAggregateFunction	From	To
	Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest.TupleKeySelector to private serialVersionUID : long from class org.apache.flink.api.common.functions.RichAggregateFunction	From	To
	Change Variable Type	1
	Change Variable Type stateDesc : AggregatingStateDescriptor<T,ACC,R> to stateDesc : AggregatingStateDescriptor<T,ACC,V> in method public aggregate(aggregateFunction AggregateFunction<T,ACC,V>, windowFunction WindowFunction<V,R,K,W>, accumulatorType TypeInformation<ACC>, aggregateResultType TypeInformation<V>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream	From	To
	Change Attribute Type	2
	Change Attribute Type aggFunction : AggregateFunction<T,ACC,R> to aggFunction : AggregateFunction<T,ACC,V> in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction	From	To
	Change Attribute Type aggFunction : AggregateFunction<T,ACC,R> to aggFunction : AggregateFunction<T,ACC,V> in class org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction	From	To