e0819dc7b72487670dd3ba06628980e27fdbedb0
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method private restoreTimers(in DataInputViewStreamWrapper) : void renamed to private restoreFromLegacyWindowOperator(in DataInputViewStreamWrapper) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type stateHandle : StreamStateHandle to stateHandles : OperatorStateHandles in method public restore(stateHandles OperatorStateHandles) : void in class org.apache.flink.streaming.util.WindowingTestHarness | From | To | |
| Change Return Type | 1 | ||
| Change Return Type StreamStateHandle to OperatorStateHandles in method public snapshot(checkpointId long, timestamp long) : OperatorStateHandles in class org.apache.flink.streaming.util.WindowingTestHarness | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testSnapshotingAndRecovery() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowingTestHarnessTest | From | To | |
| Extract Method | 2 | ||
| Extract Method private reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, resultType TypeInformation<R>, legacyWindowOpType LegacyWindowOperatorType) : SingleOutputStreamOperator<R> extracted from public reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To | |
| Extract Method private reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, legacyWindowOpType LegacyWindowOperatorType) : SingleOutputStreamOperator<R> extracted from public reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter stateHandle : StreamStateHandle to stateHandles : OperatorStateHandles in method public restore(stateHandles OperatorStateHandles) : void in class org.apache.flink.streaming.util.WindowingTestHarness | From | To |