|
Pull Up Method private resetCapacity(rc ResourceCalculator, clusterResource Resource, queues Collection<TempQueuePerPartition>, ignoreGuar boolean) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptableResourceCalculator to private resetCapacity(clusterResource Resource, queues Collection<TempQueuePerPartition>, ignoreGuar boolean) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptableResourceCalculator |
From |
To |
|
Pull Up Method protected getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptableResourceCalculator to private getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptableResourceCalculator |
From |
To |
|
Pull Up Method public getActuallyToBePreempted() : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to public getActuallyToBePreempted() : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Method public setActuallyToBePreempted(res Resource) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to public setActuallyToBePreempted(actuallyToBePreempted Resource) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Method public getUsed() : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to public getUsed() : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Method package sortContainers(containers List<RMContainer>) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.FifoCandidatesSelector to package sortContainers(containers List<RMContainer>) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptionCandidatesSelector |
From |
To |
|
Pull Up Method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptableResourceCalculator to protected computeFixpointAllocation(totGuarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptableResourceCalculator |
From |
To |
|
Move Method private addToPreemptMap(preemptMap Map<ApplicationAttemptId,Set<RMContainer>>, appAttemptId ApplicationAttemptId, containerToPreempt RMContainer) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.FifoCandidatesSelector to private addToPreemptMap(preemptMap Map<ApplicationAttemptId,Set<RMContainer>>, appAttemptId ApplicationAttemptId, containerToPreempt RMContainer) : void from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionUtils |
From |
To |
|
Move Method private getPartitionByNodeId(nodeId NodeId) : String from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.FifoCandidatesSelector to private getPartitionByNodeId(context CapacitySchedulerPreemptionContext, nodeId NodeId) : String from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionUtils |
From |
To |
|
Move Method private tryPreemptContainerAndDeductResToObtain(resourceToObtainByPartitions Map<String,Resource>, rmContainer RMContainer, clusterResource Resource, preemptMap Map<ApplicationAttemptId,Set<RMContainer>>, totalPreemptionAllowed Resource) : boolean from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.FifoCandidatesSelector to public tryPreemptContainerAndDeductResToObtain(rc ResourceCalculator, context CapacitySchedulerPreemptionContext, resourceToObtainByPartitions Map<String,Resource>, rmContainer RMContainer, clusterResource Resource, preemptMap Map<ApplicationAttemptId,Set<RMContainer>>, totalPreemptionAllowed Resource) : boolean from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.CapacitySchedulerPreemptionUtils |
From |
To |
|
Pull Up Attribute private actuallyToBePreempted : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to private actuallyToBePreempted : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Attribute private rc : ResourceCalculator from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptableResourceCalculator to protected rc : ResourceCalculator from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptableResourceCalculator |
From |
To |
|
Pull Up Attribute package toBePreempted : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to package toBePreempted : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Attribute package idealAssigned : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to package idealAssigned : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Attribute package queueName : String from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to package queueName : String from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Attribute private context : CapacitySchedulerPreemptionContext from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.PreemptableResourceCalculator to protected context : CapacitySchedulerPreemptionContext from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptableResourceCalculator |
From |
To |
|
Pull Up Attribute private current : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to protected current : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Attribute package pending : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to protected pending : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Pull Up Attribute private reserved : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition to protected reserved : Resource from class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Rename Parameter tot_guarant : Resource to totGuarant : Resource in method protected computeFixpointAllocation(totGuarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptableResourceCalculator |
From |
To |
|
Rename Parameter res : Resource to actuallyToBePreempted : Resource in method public setActuallyToBePreempted(actuallyToBePreempted Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.AbstractPreemptionEntity |
From |
To |
|
Rename Parameter application : FiCaSchedulerApp to userName : String in method private computeUserLimit(userName String, clusterResource Resource, user User, nodePartition String, schedulingMode SchedulingMode) : Resource in class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.LeafQueue |
From |
To |