555837cd6da98b0311a7f752a3b2523f6efbf6a1
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 12
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type second : T2 to second : I2 in method public join(first I1, second I2) : Tuple2<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.DefaultJoinFunction | From | To | |
| Change Parameter Type first : T1 to first : I1 in method public join(first I1, second I2) : Tuple2<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.DefaultJoinFunction | From | To | |
| Change Return Type | 4 | ||
| Change Return Type FinalizeStreamJoin<I1,I2> to JoinedStream<I1,I2> in method public equalTo(fields String...) : JoinedStream<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.JoinPredicate | From | To | |
| Change Return Type FinalizeStreamJoin<I1,I2> to JoinedStream<I1,I2> in method public equalTo(fields int...) : JoinedStream<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.JoinPredicate | From | To | |
| Change Return Type Tuple2<T1,T2> to Tuple2<I1,I2> in method public join(first I1, second I2) : Tuple2<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.DefaultJoinFunction | From | To | |
| Change Return Type FinalizeStreamJoin<I1,I2> to JoinedStream<I1,I2> in method public equalTo(keySelector KeySelector<I2,K>) : JoinedStream<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.JoinPredicate | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.datastream.StreamJoinOperator.FinalizeStreamJoin renamed to org.apache.flink.streaming.api.datastream.StreamJoinOperator.JoinedStream | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type joinedStream : DataStream<Tuple2<Tuple2<String,Integer>,Tuple2<String,Integer>>> to joinedStream : DataStream<Tuple3<String,Integer,Integer>> in method public main(args String[]) : void in class org.apache.flink.streaming.examples.join.WindowJoin | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type typeInfo : TypeInformation<OUT> to typeInfo : TypeInformation in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Change Attribute Type outTuple : Tuple2<T1,T2> to outTuple : Tuple2<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.DefaultJoinFunction | From | To |