0571094885da2766dfb52a6fb38020cab7602114
Files Diff
- Added: 1
- Removed: 3
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type op : OperatorStateCarrier<?> to op : StatefulTask<?> in method public setOperatorState(op StatefulTask<?>, state StateHandle<?>) : void in class org.apache.flink.runtime.state.StateUtils | From | To | |
| Rename Variable | 2 | ||
| Rename Variable checkpointer : CheckpointedOperator to statefulTask : StatefulTask<?> in method public triggerCheckpointBarrier(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Variable checkpointer : CheckpointNotificationOperator to statefulTask : StatefulTask<?> in method public notifyCheckpointComplete(checkpointID long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.runtime.jobgraph.tasks.OperatorStateCarrier renamed to org.apache.flink.runtime.jobgraph.tasks.StatefulTask | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type checkpointer : CheckpointNotificationOperator to statefulTask : StatefulTask<?> in method public notifyCheckpointComplete(checkpointID long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Variable Type typedOp : OperatorStateCarrier<T> to typedOp : StatefulTask<T> in method public setOperatorState(op StatefulTask<?>, state StateHandle<?>) : void in class org.apache.flink.runtime.state.StateUtils | From | To | |
| Change Variable Type op : OperatorStateCarrier<?> to op : StatefulTask<?> in method public run() : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Variable Type checkpointer : CheckpointedOperator to statefulTask : StatefulTask<?> in method public triggerCheckpointBarrier(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.runtime.jobgraph.tasks.StatefulTask from classes [org.apache.flink.runtime.taskmanager.TaskAsyncCallTest.CheckpointsInOrderInvokable, org.apache.flink.streaming.runtime.tasks.StreamTask] | From | To |