9b7f8aa121e4a231632296d0809029aca9ebde6a
Files Diff
- Added: 8
- Removed: 3
- Renamed: 0
- Modified: 27
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public triggerCheckpointBarrier(checkpointID long) : void renamed to public confirmCheckpoint(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Method public injectState(stateHandle StateHandle) : void renamed to public setInitialState(stateHandle LocalStateHandle) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type stateHandle : StateHandle to stateHandle : LocalStateHandle in method public setInitialState(stateHandle LocalStateHandle) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Parameter Type state : StateHandle to state : SerializedValue<StateHandle<?>> in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointId long, state SerializedValue<StateHandle<?>>) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint | From | To | |
| Change Parameter Type state : StateHandle to state : SerializedValue<StateHandle<?>> in method public StateForTask(state SerializedValue<StateHandle<?>>, operatorId JobVertexID, subtask int) in class org.apache.flink.runtime.checkpoint.StateForTask | From | To | |
| Change Parameter Type state : StateHandle to state : SerializedValue<StateHandle<?>> in method public acknowledgeTask(attemptID ExecutionAttemptID, state SerializedValue<StateHandle<?>>) : boolean in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Rename Variable | 3 | ||
| Rename Variable barrierTransceiver : BarrierTransceiver to checkpointer : CheckpointCommittingOperator in method public confirmCheckpoint(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Variable invokabe : AbstractInvokable to invokable : AbstractInvokable in method public confirmCheckpoint(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Variable caller : Thread to thread : Thread in method private executeAsyncCallRunnable(runnable Runnable, callName String) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Return Type | 3 | ||
| Change Return Type StateHandle to SerializedValue<StateHandle<?>> in method public getState() : SerializedValue<StateHandle<?>> in class org.apache.flink.runtime.checkpoint.StateForTask | From | To | |
| Change Return Type Map<String,OperatorState<?>> to Serializable in method public getState() : Serializable in class org.apache.flink.runtime.messages.CheckpointMessagesTest.MyHandle | From | To | |
| Change Return Type StateHandle to SerializedValue<StateHandle<?>> in method public getState() : SerializedValue<StateHandle<?>> in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.runtime.messages.checkpoint.AbortCheckpoint moved and renamed to org.apache.flink.runtime.util.SerializableObject | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute timeoutTimer : Timer to timer : Timer in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type barrierTransceiver : BarrierTransceiver to checkpointer : CheckpointCommittingOperator in method public confirmCheckpoint(checkpointID long, checkpointTimestamp long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Extract Method | 2 | ||
| Extract Method private executeAsyncCallRunnable(runnable Runnable, callName String) : void extracted from public triggerCheckpointBarrier(checkpointID long) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Extract Method private configureCheckpointing() : void extracted from public createJobGraph(jobName String) : JobGraph in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator | From | To | |
| Change Attribute Type | 6 | ||
| Change Attribute Type operatorState : StateHandle to operatorState : SerializedValue<StateHandle<?>> in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Attribute Type state : StateHandle to state : SerializedValue<StateHandle<?>> in class org.apache.flink.runtime.checkpoint.StateForTask | From | To | |
| Change Attribute Type progressLock : Object to progressLock : SerializableObject in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Change Attribute Type state : StateHandle to state : SerializedValue<StateHandle<?>> in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint | From | To | |
| Change Attribute Type stateMonitor : Object to stateMonitor : SerializableObject in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex | From | To | |
| Change Attribute Type operatorState : StateHandle to operatorState : SerializedValue<StateHandle<?>> in class org.apache.flink.runtime.taskmanager.Task | From | To |