1c87d8bcf07ea8a4f6c4bf0d7b39b20aea36b225
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Method | 2 | ||
| Move Method public coWindow(first List<IN1>, second List<IN2>, out Collector<OUT>) : void from class org.apache.flink.streaming.api.datastream.ConnectedDataStream.CrossWindowFunction to public coWindow(first List<IN1>, second List<IN2>, out Collector<OUT>) : void from class org.apache.flink.streaming.api.function.co.CrossWindowFunction | From | To | |
| Move Method public CrossWindowFunction(crossFunction CrossFunction<IN1,IN2,OUT>) from class org.apache.flink.streaming.api.datastream.ConnectedDataStream.CrossWindowFunction to public CrossWindowFunction(crossFunction CrossFunction<IN1,IN2,OUT>) from class org.apache.flink.streaming.api.function.co.CrossWindowFunction | From | To | |
| Change Return Type | 3 | ||
| Change Return Type SingleOutputStreamOperator<Tuple2<I1,I2>,?> to FinalizeStreamJoin<I1,I2> in method public equalTo(fields int...) : FinalizeStreamJoin<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.JoinPredicate | From | To | |
| Change Return Type SingleOutputStreamOperator<Tuple2<I1,I2>,?> to FinalizeStreamJoin<I1,I2> in method public equalTo(fields String...) : FinalizeStreamJoin<I1,I2> in class org.apache.flink.streaming.api.datastream.StreamJoinOperator.JoinPredicate | From | To | |
| Change Return Type SingleOutputStreamOperator<Tuple2<I1,I2>,?> to FinalizeStreamJoin<I1,I2> in method public equalTo(keySelector KeySelector<I2,K>) : FinalizeStreamJoin<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.WindowDBOperator renamed to org.apache.flink.streaming.api.datastream.TemporalOperator | From | To |