94cba8998c726092e2cc80fd022ca40bf0c38ec2
Files Diff
- Added: 11
- Removed: 6
- Renamed: 0
- Modified: 19
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Class | 3 | ||
| Rename Class org.apache.flink.streaming.api.functions.windowing.ReduceWindowFunction renamed to org.apache.flink.streaming.api.functions.windowing.PassThroughWindowFunction | From | To | |
| Rename Class org.apache.flink.streaming.api.operators.FoldWindowFunctionTest renamed to org.apache.flink.streaming.api.operators.FoldApplyWindowFunctionTest | From | To | |
| Rename Class org.apache.flink.streaming.api.functions.windowing.ReduceAllWindowFunction renamed to org.apache.flink.streaming.api.functions.windowing.PassThroughAllWindowFunction | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type foldWindowFunction : FoldWindowFunction<Integer,TimeWindow,Integer,Integer> to foldWindowFunction : FoldApplyWindowFunction<Integer,TimeWindow,Integer,Integer> in method public testFoldWindowFunctionOutputTypeConfigurable() : void in class org.apache.flink.streaming.api.operators.FoldApplyWindowFunctionTest | From | To | |
| Extract Method | 2 | ||
| Extract Method public apply(initialValue R, foldFunction FoldFunction<T,R>, function AllWindowFunction<R,R,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> extracted from public fold(initialValue R, function FoldFunction<T,R>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream | From | To | |
| Extract Method public apply(initialValue R, foldFunction FoldFunction<T,R>, function WindowFunction<R,R,K,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> extracted from public fold(initialValue R, function FoldFunction<T,R>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To |