0735b5b935b0c0757943e2d58047afcfb9949560
Files Diff
- Added: 6
- Removed: 1
- Renamed: 0
- Modified: 16
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type listener : ActorGateway to listener : TaskExecutionStateListener in method public registerExecutionListener(listener TaskExecutionStateListener) : void in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Parameter Type jobManager : ActorGateway to checkpointResponder : CheckpointResponder in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, executionConfig ExecutionConfig, taskInfo TaskInfo, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, kvStateRegistry TaskKvStateRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], checkpointResponder CheckpointResponder, taskManagerInfo TaskManagerRuntimeInfo, metrics TaskMetricGroup, containingTask Task) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Rename Variable | 1 | ||
| Rename Variable executionStateListener : ExecutionStateListener to testingExecutionStateListener : TestingExecutionStateListener in method public testEarlyCanceling() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Rename Attribute | 4 | ||
| Rename Attribute jobId : JobID to jobID : JobID in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To | |
| Rename Attribute jobManager : ActorGateway to checkpointResponder : CheckpointResponder in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Rename Attribute executionListenerActors : List<ActorGateway> to taskExecutionStateListeners : List<TaskExecutionStateListener> in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Attribute vertexId : JobVertexID to vertexID : JobVertexID in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type executionStateListener : ExecutionStateListener to testingExecutionStateListener : TestingExecutionStateListener in method public testEarlyCanceling() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type jobManager : ActorGateway to checkpointResponder : CheckpointResponder in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Change Attribute Type executionListenerActors : List<ActorGateway> to taskExecutionStateListeners : List<TaskExecutionStateListener> in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter jobManager : ActorGateway to checkpointResponder : CheckpointResponder in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, executionConfig ExecutionConfig, taskInfo TaskInfo, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, kvStateRegistry TaskKvStateRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], checkpointResponder CheckpointResponder, taskManagerInfo TaskManagerRuntimeInfo, metrics TaskMetricGroup, containingTask Task) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Rename Parameter vertexId : JobVertexID to vertexID : JobVertexID in method public TaskInputSplitProvider(jobManager ActorGateway, jobID JobID, vertexID JobVertexID, executionID ExecutionAttemptID, timeout FiniteDuration) in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To | |
| Rename Parameter jobId : JobID to jobID : JobID in method public TaskInputSplitProvider(jobManager ActorGateway, jobID JobID, vertexID JobVertexID, executionID ExecutionAttemptID, timeout FiniteDuration) in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider | From | To |