b0a2e4a14e0161e753ec3296d4ead8e46ac8e303
Files Diff
- Added: 5
- Removed: 3
- Renamed: 0
- Modified: 13
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Move Class | 3 | ||
Move Class org.apache.flink.streaming.api.datastream.StreamCrossOperator moved to org.apache.flink.streaming.api.datastream.temporaloperator.StreamCrossOperator | From | To | |
Move Class org.apache.flink.streaming.api.datastream.TemporalOperator moved to org.apache.flink.streaming.api.datastream.temporaloperator.TemporalOperator | From | To | |
Move Class org.apache.flink.streaming.api.datastream.StreamJoinOperator moved to org.apache.flink.streaming.api.datastream.temporaloperator.StreamJoinOperator | From | To | |
Merge Parameter | 1 | ||
Merge Parameter [windowSize : long, slideInterval : long] to timeUnit : TimeUnit in method public onWindow(length long, timeUnit TimeUnit) : OP in class org.apache.flink.streaming.api.datastream.temporaloperator.TemporalOperator | From | To | |
Rename Parameter | 2 | ||
Rename Parameter windowSize : long to length : long in method public onWindow(length long, timeUnit TimeUnit) : OP in class org.apache.flink.streaming.api.datastream.temporaloperator.TemporalOperator | From | To | |
Rename Parameter windowSize : long to length : long in method private onWindow(length long, timeStamp1 TimestampWrapper<I1>, timeStamp2 TimestampWrapper<I2>) : OP in class org.apache.flink.streaming.api.datastream.temporaloperator.TemporalOperator | From | To |