org.apache.hadoop.yarn.server.resourcemanager.reservation.planning

Class StageAllocatorGreedyRLE

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.reservation.planning.StageAllocatorGreedyRLE

All Implemented Interfaces:

StageAllocator

public class StageAllocatorGreedyRLE
extends Object
implements StageAllocator

Computes the stage allocation according to the greedy allocation rule. The greedy rule repeatedly allocates requested containers at the leftmost or rightmost possible interval. This implementation leverages the run-length-encoding of the time-series we operate on and proceed more quickly than the baseline.

Constructor Summary

Constructors

Constructor and Description
StageAllocatorGreedyRLE(boolean allocateLeft)

Method Summary

Methods

Modifier and Type	Method and Description
Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource>	computeStageAllocation(Plan plan, Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageEarliestStart, long stageDeadline, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) Computes the allocation of a stage inside a defined time interval.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StageAllocatorGreedyRLE

public StageAllocatorGreedyRLE(boolean allocateLeft)

Method Detail

computeStageAllocation

public Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> computeStageAllocation(Plan plan,
                                                                                          Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
                                                                                          RLESparseResourceAllocation planModifications,
                                                                                          org.apache.hadoop.yarn.api.records.ReservationRequest rr,
                                                                                          long stageEarliestStart,
                                                                                          long stageDeadline,
                                                                                          String user,
                                                                                          org.apache.hadoop.yarn.api.records.ReservationId oldId)
                                                                                            throws PlanningException

Description copied from interface: StageAllocator

Computes the allocation of a stage inside a defined time interval.

Specified by:

computeStageAllocation in interface StageAllocator

Parameters:

plan - the Plan to which the reservation must be fitted

planLoads - a 'dirty' read of the plan loads at each time

planModifications - the allocations performed by the planning algorithm which are not yet reflected by plan

rr - the stage

stageEarliestStart - the arrival time (earliest starting time) set for the stage by the two phase planning algorithm

stageDeadline - the deadline of the stage set by the two phase planning algorithm

Returns:

The computed allocation (or null if the stage could not be allocated)

Throws:

PlanningException