|
Change Parameter Type q : TempQueue to q : TempQueuePerPartition in method public addChild(q TempQueuePerPartition) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TempQueuePerPartition |
From |
To |
|
Change Parameter Type unorderedqueues : List<TempQueue> to leafQueueNames : List<String> in method private logToCSV(leafQueueNames List<String>) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Parameter Type tq1 : TempQueue to tq1 : TempQueuePerPartition in method public compare(tq1 TempQueuePerPartition, tq2 TempQueuePerPartition) : int in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TQComparator |
From |
To |
|
Change Parameter Type q : TempQueue to q : TempQueuePerPartition in method private getIdealPctOfGuaranteed(q TempQueuePerPartition) : double in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TQComparator |
From |
To |
|
Change Parameter Type queues : Collection<TempQueue> to queues : Collection<TempQueuePerPartition> in method private resetCapacity(rc ResourceCalculator, clusterResource Resource, queues Collection<TempQueuePerPartition>, ignoreGuar boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Parameter Type queues : ArrayList<TempQueue> to queues : ArrayList<TempQueuePerPartition> in method public addChildren(queues ArrayList<TempQueuePerPartition>) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TempQueuePerPartition |
From |
To |
|
Change Parameter Type queues : List<TempQueue> to queues : List<TempQueuePerPartition> in method private computeIdealResourceDistribution(rc ResourceCalculator, queues List<TempQueuePerPartition>, totalPreemptionAllowed Resource, tot_guarant Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Parameter Type qAlloc : Collection<TempQueue> to qAlloc : Collection<TempQueuePerPartition> in method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Parameter Type orderedByNeed : PriorityQueue<TempQueue> to orderedByNeed : PriorityQueue<TempQueuePerPartition> in method protected getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Parameter Type tq2 : TempQueue to tq2 : TempQueuePerPartition in method public compare(tq1 TempQueuePerPartition, tq2 TempQueuePerPartition) : int in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TQComparator |
From |
To |
|
Change Parameter Type root : TempQueue to root : TempQueuePerPartition in method private recursivelyComputeIdealAssignment(root TempQueuePerPartition, totalPreemptionAllowed Resource) : Set<String> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Rename Variable leafs : List<TempQueue> to leafQueueNames : Set<String> in method private recursivelyComputeIdealAssignment(root TempQueuePerPartition, totalPreemptionAllowed Resource) : Set<String> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Rename Variable queues : List<TempQueue> to leafQueueNames : Set<String> in method private containerBasedPreemptOrKill(root CSQueue, clusterResources Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Rename Variable containers : List<RMContainer> to liveContainers : List<RMContainer> in method private preemptFrom(app FiCaSchedulerApp, clusterResource Resource, resToObtainByPartition Map<String,Resource>, skippedAMContainerlist List<RMContainer>, skippedAMSize Resource, preemptMap Map<ApplicationAttemptId,Set<RMContainer>>) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Rename Variable reservations : List<RMContainer> to reservedContainers : List<RMContainer> in method private preemptFrom(app FiCaSchedulerApp, clusterResource Resource, resToObtainByPartition Map<String,Resource>, skippedAMContainerlist List<RMContainer>, skippedAMSize Resource, preemptMap Map<ApplicationAttemptId,Set<RMContainer>>) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Return Type Collection<TempQueue> to Collection<TempQueuePerPartition> in method protected getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Return Type Set<RMContainer> to void in method private preemptFrom(app FiCaSchedulerApp, clusterResource Resource, resToObtainByPartition Map<String,Resource>, skippedAMContainerlist List<RMContainer>, skippedAMSize Resource, preemptMap Map<ApplicationAttemptId,Set<RMContainer>>) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Return Type List<TempQueue> to Set<String> in method private recursivelyComputeIdealAssignment(root TempQueuePerPartition, totalPreemptionAllowed Resource) : Set<String> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Return Type ArrayList<TempQueue> to ArrayList<TempQueuePerPartition> in method public getChildren() : ArrayList<TempQueuePerPartition> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TempQueuePerPartition |
From |
To |
|
Change Return Type TempQueue to TempQueuePerPartition in method private cloneQueues(curQueue CSQueue, partitionResource Resource, partitionToLookAt String) : TempQueuePerPartition in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type sub : TempQueue to sub : TempQueuePerPartition in method public printAll() : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy.TempQueuePerPartition |
From |
To |
|
Change Variable Type qAlloc : List<TempQueue> to qAlloc : List<TempQueuePerPartition> in method private computeIdealResourceDistribution(rc ResourceCalculator, queues List<TempQueuePerPartition>, totalPreemptionAllowed Resource, tot_guarant Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type leafs : List<TempQueue> to leafQueueNames : Set<String> in method private recursivelyComputeIdealAssignment(root TempQueuePerPartition, totalPreemptionAllowed Resource) : Set<String> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type ret : TempQueue to ret : TempQueuePerPartition in method private cloneQueues(curQueue CSQueue, partitionResource Resource, partitionToLookAt String) : TempQueuePerPartition in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type q : TempQueue to q : TempQueuePerPartition in method private resetCapacity(rc ResourceCalculator, clusterResource Resource, queues Collection<TempQueuePerPartition>, ignoreGuar boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type sub : TempQueue to sub : TempQueuePerPartition in method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type subq : TempQueue to subq : TempQueuePerPartition in method private cloneQueues(curQueue CSQueue, partitionResource Resource, partitionToLookAt String) : TempQueuePerPartition in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type i : Iterator<TempQueue> to i : Iterator<TempQueuePerPartition> in method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type q : TempQueue to q : TempQueuePerPartition in method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type orderedByNeed : PriorityQueue<TempQueue> to orderedByNeed : PriorityQueue<TempQueuePerPartition> in method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type t : TempQueue to t : TempQueuePerPartition in method private recursivelyComputeIdealAssignment(root TempQueuePerPartition, totalPreemptionAllowed Resource) : Set<String> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type zeroGuarQueues : Set<TempQueue> to zeroGuarQueues : Set<TempQueuePerPartition> in method private computeIdealResourceDistribution(rc ResourceCalculator, queues List<TempQueuePerPartition>, totalPreemptionAllowed Resource, tot_guarant Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type queues : List<TempQueue> to leafQueueNames : Set<String> in method private containerBasedPreemptOrKill(root CSQueue, clusterResources Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type underserved : ArrayList<TempQueue> to underserved : ArrayList<TempQueuePerPartition> in method protected getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type q1 : TempQueue to q1 : TempQueuePerPartition in method protected getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type t : TempQueue to t : TempQueuePerPartition in method private computeIdealResourceDistribution(rc ResourceCalculator, queues List<TempQueuePerPartition>, totalPreemptionAllowed Resource, tot_guarant Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type q2 : TempQueue to q2 : TempQueuePerPartition in method protected getMostUnderservedQueues(orderedByNeed PriorityQueue<TempQueuePerPartition>, tqComparator TQComparator) : Collection<TempQueuePerPartition> in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type underserved : Collection<TempQueue> to underserved : Collection<TempQueuePerPartition> in method private computeFixpointAllocation(rc ResourceCalculator, tot_guarant Resource, qAlloc Collection<TempQueuePerPartition>, unassigned Resource, ignoreGuarantee boolean) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type nonZeroGuarQueues : Set<TempQueue> to nonZeroGuarQueues : Set<TempQueuePerPartition> in method private computeIdealResourceDistribution(rc ResourceCalculator, queues List<TempQueuePerPartition>, totalPreemptionAllowed Resource, tot_guarant Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |
|
Change Variable Type q : TempQueue to q : TempQueuePerPartition in method private computeIdealResourceDistribution(rc ResourceCalculator, queues List<TempQueuePerPartition>, totalPreemptionAllowed Resource, tot_guarant Resource) : void in class org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.ProportionalCapacityPreemptionPolicy |
From |
To |