8bf9416d37ae43d868ffaaf7b1fac0fe9fb43c03
Files Diff
- Added: 1
- Removed: 8
- Renamed: 0
- Modified: 17
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 1 | ||
Change Parameter Type value : Integer to value : Tuple1<Integer> in method public getTimestamp(value Tuple1<Integer>) : long in class org.apache.flink.streaming.api.WindowCrossJoinTest.MyTimestamp2 | From | To | |
Change Return Type | 2 | ||
Change Return Type Object to Tuple in method public getKey(value IN) : Tuple in class org.apache.flink.streaming.util.keys.KeySelectorUtil.ArrayKeySelector | From | To | |
Change Return Type IN to Tuple in method public getKey(value IN) : Tuple in class org.apache.flink.streaming.util.keys.KeySelectorUtil.ComparableKeySelector | From | To | |
Move And Rename Class | 1 | ||
Move And Rename Class org.apache.flink.streaming.util.keys.ObjectKeySelector moved and renamed to org.apache.flink.streaming.util.keys.KeySelectorUtil.ComparableKeySelector | From | To | |
Move Class | 1 | ||
Move Class org.apache.flink.streaming.util.keys.ArrayKeySelector moved to org.apache.flink.streaming.util.keys.KeySelectorUtil.ArrayKeySelector | From | To | |
Change Variable Type | 2 | ||
Change Variable Type in2 : ArrayList<Integer> to in2 : ArrayList<Tuple1<Integer>> in method public test() : void in class org.apache.flink.streaming.api.WindowCrossJoinTest | From | To | |
Change Variable Type inStream2 : DataStream<Integer> to inStream2 : DataStream<Tuple1<Integer>> in method public test() : void in class org.apache.flink.streaming.api.WindowCrossJoinTest | From | To | |
Extract Variable | 2 | ||
Extract Variable key2 : Object in method public coWindow(first List<IN1>, second List<IN2>, out Collector<OUT>) : void from class org.apache.flink.streaming.api.function.co.JoinWindowFunction | From | To | |
Extract Variable key1 : Object in method public coWindow(first List<IN1>, second List<IN2>, out Collector<OUT>) : void from class org.apache.flink.streaming.api.function.co.JoinWindowFunction | From | To |