67ed642ca42cd6c2beb240eeb0fe18f24ea22874
Files Diff
- Added: 5
- Removed: 0
- Renamed: 0
- Modified: 27
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public getAllocationID() : AllocationID renamed to public getAllocationId() : AllocationID in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor | From | To | |
| Rename Method public existActiveSlot(jobId JobID, allocationId AllocationID) : boolean renamed to public existsActiveSlot(jobId JobID, allocationId AllocationID) : boolean in class org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable | From | To | |
| Rename Method public getJobMasterLeaderId() : UUID renamed to public getLeaderId() : UUID in class org.apache.flink.runtime.taskexecutor.JobManagerConnection | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type jobManagerID : ResourceID to jobManagerLeaderId : UUID in method public submitTask(tdd TaskDeploymentDescriptor, jobManagerLeaderId UUID) : Acknowledge in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Change Parameter Type partitionInfos : Collection<PartitionInfo> to partitionInfos : Iterable<PartitionInfo> in method public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>) : Acknowledge in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Rename Variable | 3 | ||
| Rename Variable rpcEndpointValueClass : Class<?> to fullRpcEndpointValueTypeInfo : ReflectionUtil.FullTypeInfo in method private checkMethod(gatewayMethod Method, endpointMethod Method) : boolean in class org.apache.flink.runtime.rpc.RpcCompletenessTest | From | To | |
| Rename Variable valueClass : Class<?> to fullTypeInfo : ReflectionUtil.FullTypeInfo in method private generateEndpointMethodSignature(method Method) : String in class org.apache.flink.runtime.rpc.RpcCompletenessTest | From | To | |
| Rename Variable valueClass : Class<?> to fullValueTypeInfo : ReflectionUtil.FullTypeInfo in method private checkMethod(gatewayMethod Method, endpointMethod Method) : boolean in class org.apache.flink.runtime.rpc.RpcCompletenessTest | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute jobMasterLeaderId : UUID to leaderId : UUID in class org.apache.flink.runtime.taskexecutor.JobManagerConnection | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type valueClass : Class<?> to fullValueTypeInfo : ReflectionUtil.FullTypeInfo in method private checkMethod(gatewayMethod Method, endpointMethod Method) : boolean in class org.apache.flink.runtime.rpc.RpcCompletenessTest | From | To | |
| Change Variable Type rpcEndpointValueClass : Class<?> to fullRpcEndpointValueTypeInfo : ReflectionUtil.FullTypeInfo in method private checkMethod(gatewayMethod Method, endpointMethod Method) : boolean in class org.apache.flink.runtime.rpc.RpcCompletenessTest | From | To | |
| Change Variable Type valueClass : Class<?> to fullTypeInfo : ReflectionUtil.FullTypeInfo in method private generateEndpointMethodSignature(method Method) : String in class org.apache.flink.runtime.rpc.RpcCompletenessTest | From | To | |
| Extract Variable | 1 | ||
| Extract Variable jobId : JobID in method public submitTask(tdd TaskDeploymentDescriptor, jobManagerLeaderId UUID) : Acknowledge from class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Extract Method | 1 | ||
| Extract Method private freeSlot(allocationId AllocationID, cause Throwable) : void extracted from private freeSlot(allocationId AllocationID) : void in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter jobMasterLeaderId : UUID to leaderId : UUID in method public JobManagerConnection(jobMasterGateway JobMasterGateway, leaderId UUID, taskManagerActions TaskManagerActions, checkpointResponder CheckpointResponder, libraryCacheManager LibraryCacheManager, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionStateChecker PartitionProducerStateChecker) in class org.apache.flink.runtime.taskexecutor.JobManagerConnection | From | To | |
| Rename Parameter jobMasterLeaderId : UUID to jobManagerLeaderId : UUID in method private associateWithJobManager(jobMasterGateway JobMasterGateway, jobManagerLeaderId UUID, blobPort int) : JobManagerConnection in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Rename Parameter jobManagerID : ResourceID to jobManagerLeaderId : UUID in method public submitTask(tdd TaskDeploymentDescriptor, jobManagerLeaderId UUID) : Acknowledge in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To |