0dac7ad00a25c4b038b57009f41f5512f8ce73c3
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 25
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type checkpointId : long to checkpointMetaData : CheckpointMetaData in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointMetaData CheckpointMetaData) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint | From | To | |
| Change Parameter Type checkpointId : long to checkpointMetaData : CheckpointMetaData in method package AsyncCheckpointRunnable(name String, owner StreamTask<?,?>, cancelables ClosableRegistry, nonPartitionedStateHandles ChainedStateHandle<StreamStateHandle>, partitioneableStateHandles ChainedStateHandle<OperatorStateHandle>, keyGroupsStateHandleFuture RunnableFuture<KeyGroupsStateHandle>, checkpointMetaData CheckpointMetaData, asyncStartNanos long) in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable | From | To | |
| Rename Variable | 1 | ||
| Rename Variable endOfSyncPart : long to syncEndNanos : long in method private performCheckpoint(checkpointMetaData CheckpointMetaData) : boolean in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private checkpointId : long from class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable to private checkpointId : long from class org.apache.flink.runtime.checkpoint.CheckpointMetaData | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.runtime.checkpoint.CheckpointMetaData from class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable | From | To | |
| Merge Parameter | 6 | ||
| Merge Parameter [checkpointID : long, synchronousDurationMillis : long, asynchronousDurationMillis : long, bytesBufferedInAlignment : long, alignmentDurationNanos : long] to checkpointMetaData : CheckpointMetaData in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointMetaData CheckpointMetaData, checkpointStateHandles CheckpointStateHandles) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayCheckpointResponder | From | To | |
| Merge Parameter [checkpointId : long, timestamp : long, bytesAligned : long, alignmentTimeNanos : long] to checkpointMetaData : CheckpointMetaData in method public triggerCheckpointOnBarrier(checkpointMetaData CheckpointMetaData) : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest.ValidatingCheckpointHandler | From | To | |
| Merge Parameter [checkpointId : long, timestamp : long] to checkpointMetaData : CheckpointMetaData in method public triggerCheckpointOnBarrier(checkpointMetaData CheckpointMetaData) : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest.CheckpointSequenceValidator | From | To | |
| Merge Parameter [checkpointId : long, synchronousDurationMillis : long, asynchronousDurationMillis : long, bytesBufferedInAlignment : long, alignmentDurationNanos : long] to checkpointMetaData : CheckpointMetaData in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointMetaData CheckpointMetaData, checkpointStateHandles CheckpointStateHandles) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint | From | To | |
| Merge Parameter [checkpointID : long, checkpointTimestamp : long] to checkpointMetaData : CheckpointMetaData in method public declineCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointMetaData CheckpointMetaData) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayCheckpointResponder | From | To | |
| Merge Parameter [alignmentDurationNanos : long, checkpointId : long, timestamp : long] to checkpointMetaData : CheckpointMetaData in method private performCheckpoint(checkpointMetaData CheckpointMetaData) : boolean in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute checkpointId : long to checkpointMetaData : CheckpointMetaData in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type checkpointId : long to checkpointMetaData : CheckpointMetaData in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter checkpointId : long to checkpointMetaData : CheckpointMetaData in method package AsyncCheckpointRunnable(name String, owner StreamTask<?,?>, cancelables ClosableRegistry, nonPartitionedStateHandles ChainedStateHandle<StreamStateHandle>, partitioneableStateHandles ChainedStateHandle<OperatorStateHandle>, keyGroupsStateHandleFuture RunnableFuture<KeyGroupsStateHandle>, checkpointMetaData CheckpointMetaData, asyncStartNanos long) in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable | From | To | |
| Rename Parameter checkpointId : long to checkpointMetaData : CheckpointMetaData in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointMetaData CheckpointMetaData) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint | From | To |