e8734b2452e31e7a35a20faaf6eb37fe59b6eff1
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 59
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method public getTaskName() : String renamed to public getTaskInfo() : TaskInfo in class org.apache.flink.runtime.execution.Environment | From | To | |
| Rename Method public getTaskName() : String renamed to public getTaskInfo() : TaskInfo in class org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment | From | To | |
| Rename Method public getIndexInSubtaskGroup() : int renamed to public getTaskInfo() : TaskInfo in class org.apache.flink.runtime.operators.testutils.MockEnvironment | From | To | |
| Rename Method public getIndexInSubtaskGroup() : int renamed to public getTaskInfo() : TaskInfo in class org.apache.flink.runtime.execution.Environment | From | To | |
| Merge Attribute | 1 | ||
| Merge Attribute [taskName : String, taskNameWithSubtask : String, subtaskIndex : int, parallelism : int] to taskInfo : TaskInfo in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method public getIndexInSubtaskGroup() : int from class org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment to public getAttemptNumber() : int from class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type taskName : String to taskInfo : TaskInfo in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, taskInfo TaskInfo, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], jobManager ActorGateway, taskManagerInfo TaskManagerRuntimeInfo) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Move Method | 9 | ||
| Move Method public getTaskNameWithSubtasks() : String from class org.apache.flink.runtime.operators.testutils.DummyEnvironment to public getTaskNameWithSubtasks() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskNameWithSubtasks() : String from class org.apache.flink.runtime.taskmanager.RuntimeEnvironment to public getTaskNameWithSubtasks() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskNameWithSubtasks() : String from class org.apache.flink.runtime.taskmanager.Task to public getTaskNameWithSubtasks() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskNameWithSubtasks() : String from class org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment to public getTaskNameWithSubtasks() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskName() : String from class org.apache.flink.runtime.operators.testutils.MockEnvironment to public getTaskName() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskName() : String from class org.apache.flink.runtime.taskmanager.RuntimeEnvironment to public getTaskName() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskName() : String from class org.apache.flink.runtime.operators.testutils.DummyEnvironment to public getTaskName() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskName() : String from class org.apache.flink.runtime.taskmanager.Task to public getTaskName() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Method public getTaskNameWithSubtasks() : String from class org.apache.flink.runtime.operators.testutils.MockEnvironment to public getTaskNameWithSubtasks() : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Rename Variable | 1 | ||
| Rename Variable taskNameWithSubtasksAndId : String to taskNameWithSubtaskAndId : String in method public Task(tdd TaskDeploymentDescriptor, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActor ActorGateway, jobManagerActor ActorGateway, actorAskTimeout FiniteDuration, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo) in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Return Type | 4 | ||
| Change Return Type int to TaskInfo in method public getTaskInfo() : TaskInfo in class org.apache.flink.runtime.execution.Environment | From | To | |
| Change Return Type int to TaskInfo in method public getTaskInfo() : TaskInfo in class org.apache.flink.runtime.operators.testutils.MockEnvironment | From | To | |
| Change Return Type String to TaskInfo in method public getTaskInfo() : TaskInfo in class org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment | From | To | |
| Change Return Type String to TaskInfo in method public getTaskInfo() : TaskInfo in class org.apache.flink.runtime.execution.Environment | From | To | |
| Move Attribute | 5 | ||
| Move Attribute private taskName : String from class org.apache.flink.runtime.operators.testutils.MockEnvironment to private taskName : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Attribute private taskName : String from class org.apache.flink.runtime.taskmanager.RuntimeEnvironment to private taskName : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Attribute private taskName : String from class org.apache.flink.runtime.operators.testutils.DummyEnvironment to private taskName : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Attribute private taskNameWithSubtasks : String from class org.apache.flink.runtime.taskmanager.RuntimeEnvironment to private taskNameWithSubtasks : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Move Attribute private taskName : String from class org.apache.flink.runtime.taskmanager.Task to private taskName : String from class org.apache.flink.api.common.TaskInfo | From | To | |
| Extract Class | 5 | ||
| Extract Class org.apache.flink.api.common.TaskInfo from class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Extract Class org.apache.flink.api.common.TaskInfo from class org.apache.flink.runtime.operators.testutils.MockEnvironment | From | To | |
| Extract Class org.apache.flink.api.common.TaskInfo from class org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment | From | To | |
| Extract Class org.apache.flink.api.common.TaskInfo from class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Extract Class org.apache.flink.api.common.TaskInfo from class org.apache.flink.runtime.operators.testutils.DummyEnvironment | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute taskName : String to taskInfo : TaskInfo in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Rename Attribute subtaskIndex : int to taskInfo : TaskInfo in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type taskName : String to taskInfo : TaskInfo in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To | |
| Change Attribute Type subtaskIndex : int to taskInfo : TaskInfo in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter taskName : String to taskInfo : TaskInfo in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, taskInfo TaskInfo, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], jobManager ActorGateway, taskManagerInfo TaskManagerRuntimeInfo) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment | From | To |