474ff4dfd93a57730969ffdd221b7ecec06ed479
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type List<OneInputStreamOperator<?,?>> to List<StreamOperator<?>> in method public getChainedOperators() : List<StreamOperator<?>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type chainedOperator : OneInputStreamOperator<?,?> to chainedOperator : StreamOperator<?> in method public triggerCheckpoint(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type stateHandle : StateHandle<Serializable> to stateHandle : WrapperStateHandle in method public triggerCheckpoint(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type chainedOperators : List<OneInputStreamOperator<?,?>> to chainedOperators : List<StreamOperator<?>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler | From | To |