402a2e30c750e1bcb753643ed66c6df0dd861112
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 16
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public getTaskStateSnapshot() : TaskStateSnapshot renamed to public getTaskRestore() : JobManagerTaskRestore in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Method public getTaskStateHandles() : TaskStateSnapshot renamed to public getTaskRestore() : JobManagerTaskRestore in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, slotAllocationId AllocationID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, taskRestore JobManagerTaskRestore, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActions TaskManagerActions, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, blobService BlobCacheService, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Parameter Type taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method public TaskDeploymentDescriptor(jobId JobID, serializedJobInformation MaybeOffloaded<JobInformation>, serializedTaskInformation MaybeOffloaded<TaskInformation>, executionAttemptId ExecutionAttemptID, allocationId AllocationID, subtaskIndex int, attemptNumber int, targetSlotNumber int, taskRestore JobManagerTaskRestore, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Change Parameter Type taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot LogicalSlot, taskRestore JobManagerTaskRestore, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Change Parameter Type checkpointStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method public setInitialState(taskRestore JobManagerTaskRestore) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Return Type | 2 | ||
| Change Return Type TaskStateSnapshot to JobManagerTaskRestore in method public getTaskRestore() : JobManagerTaskRestore in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Return Type TaskStateSnapshot to JobManagerTaskRestore in method public getTaskRestore() : JobManagerTaskRestore in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Rename Attribute taskState : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type matcher : BaseMatcher<TaskStateSnapshot> to matcher : BaseMatcher<JobManagerTaskRestore> in method public testSetState() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type taskState : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Attribute Type taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, slotAllocationId AllocationID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, taskRestore JobManagerTaskRestore, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActions TaskManagerActions, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, blobService BlobCacheService, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Parameter taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method public TaskDeploymentDescriptor(jobId JobID, serializedJobInformation MaybeOffloaded<JobInformation>, serializedTaskInformation MaybeOffloaded<TaskInformation>, executionAttemptId ExecutionAttemptID, allocationId AllocationID, subtaskIndex int, attemptNumber int, targetSlotNumber int, taskRestore JobManagerTaskRestore, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Rename Parameter taskStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot LogicalSlot, taskRestore JobManagerTaskRestore, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Rename Parameter checkpointStateHandles : TaskStateSnapshot to taskRestore : JobManagerTaskRestore in method public setInitialState(taskRestore JobManagerTaskRestore) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To |