8f3d6d239996c83f7cbd102dc8a85ee626a56bf5
Files Diff
- Added: 22
- Removed: 3
- Renamed: 0
- Modified: 28
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type taskManager : TaskManagerConnection to taskManager : TaskManagerActions in method public TaskCanceler(logger Logger, invokable AbstractInvokable, executer Thread, taskName String, cancellationInterval long, cancellationTimeout long, taskManager TaskManagerActions, producedPartitions ResultPartition[], inputGates SingleInputGate[]) in class org.apache.flink.runtime.taskmanager.Task.TaskCanceler | From | To | |
| Change Parameter Type config : Configuration to tempDirectories : String[] in method public FileCache(tempDirectories String[]) in class org.apache.flink.runtime.filecache.FileCache | From | To | |
| Change Return Type | 4 | ||
| Change Return Type NextInputSplit to SerializedInputSplit in method public requestNextInputSplit(vertexID JobVertexID, executionAttempt ExecutionAttemptID) : SerializedInputSplit in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Return Type boolean to Acknowledge in method public updateTaskExecutionState(taskExecutionState TaskExecutionState) : Acknowledge in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Return Type Future<Boolean> to Future<Acknowledge> in method public updateTaskExecutionState(taskExecutionState TaskExecutionState) : Future<Acknowledge> in class org.apache.flink.runtime.jobmaster.JobMasterGateway | From | To | |
| Change Return Type Future<NextInputSplit> to Future<SerializedInputSplit> in method public requestNextInputSplit(vertexID JobVertexID, executionAttempt ExecutionAttemptID) : Future<SerializedInputSplit> in class org.apache.flink.runtime.jobmaster.JobMasterGateway | From | To | |
| Rename Class | 2 | ||
| Rename Class org.apache.flink.runtime.taskmanager.ActorGatewayTaskManagerConnection renamed to org.apache.flink.runtime.taskmanager.ActorGatewayTaskManagerActions | From | To | |
| Rename Class org.apache.flink.runtime.taskmanager.TaskManagerConnection renamed to org.apache.flink.runtime.taskmanager.TaskManagerActions | From | To | |
| Parameterize Variable | 1 | ||
| Parameterize Variable directories : String[] to tempDirectories : String[] in method public FileCache(tempDirectories String[]) in class org.apache.flink.runtime.filecache.FileCache | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute taskManagerConnection : TaskManagerConnection to taskManagerActions : TaskManagerActions in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type taskManagerConnection : TaskManagerConnection to taskManagerActions : TaskManagerActions in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Change Attribute Type taskManagerConnection : ActorGatewayTaskManagerConnection to taskManagerConnection : ActorGatewayTaskManagerActions in class org.apache.flink.runtime.taskmanager.TaskTest | From | To | |
| Change Attribute Type taskManager : TaskManagerConnection to taskManager : TaskManagerActions in class org.apache.flink.runtime.taskmanager.Task.TaskCanceler | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter intermediateDataSetId : IntermediateDataSetID to intermediateResultId : IntermediateDataSetID in method public requestPartitionState(ignored JobID, intermediateResultId IntermediateDataSetID, resultPartitionId ResultPartitionID) : ExecutionState in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Rename Parameter config : Configuration to tempDirectories : String[] in method public FileCache(tempDirectories String[]) in class org.apache.flink.runtime.filecache.FileCache | From | To |