public class IterativePlanner extends PlanningAlgorithm
Modifier and Type | Class and Description |
---|---|
static class |
IterativePlanner.StageProvider
Helper class that provide a list of ReservationRequests and iterates
forward or backward depending whether we are allocating left-to-right or
right-to-left.
|
Constructor and Description |
---|
IterativePlanner(StageEarliestStart algEarliestStartTime,
StageAllocator algStageAllocator,
boolean allocateLeft) |
Modifier and Type | Method and Description |
---|---|
protected long |
computeEarliestStartingTime(Plan plan,
org.apache.hadoop.yarn.api.records.ReservationDefinition reservation,
int index,
org.apache.hadoop.yarn.api.records.ReservationRequest currentReservationStage,
long stageDeadline) |
RLESparseResourceAllocation |
computeJobAllocation(Plan plan,
org.apache.hadoop.yarn.api.records.ReservationId reservationId,
org.apache.hadoop.yarn.api.records.ReservationDefinition reservation,
String user) |
protected Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> |
computeStageAllocation(Plan plan,
org.apache.hadoop.yarn.api.records.ReservationRequest rr,
long stageArrivalTime,
long stageDeadline,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId) |
protected void |
initialize(Plan plan,
org.apache.hadoop.yarn.api.records.ReservationId reservationId,
org.apache.hadoop.yarn.api.records.ReservationDefinition reservation) |
IterativePlanner |
setAlgStageAllocator(StageAllocator alg) |
IterativePlanner |
setAlgStageEarliestStart(StageEarliestStart alg) |
allocateUser, createReservation, deleteReservation, findEarliestTime, findLatestTime, stepRoundDown, stepRoundUp, updateReservation
public IterativePlanner(StageEarliestStart algEarliestStartTime, StageAllocator algStageAllocator, boolean allocateLeft)
public RLESparseResourceAllocation computeJobAllocation(Plan plan, org.apache.hadoop.yarn.api.records.ReservationId reservationId, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation, String user) throws PlanningException
computeJobAllocation
in class PlanningAlgorithm
PlanningException
protected void initialize(Plan plan, org.apache.hadoop.yarn.api.records.ReservationId reservationId, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation) throws PlanningException
PlanningException
protected long computeEarliestStartingTime(Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation, int index, org.apache.hadoop.yarn.api.records.ReservationRequest currentReservationStage, long stageDeadline)
protected Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> computeStageAllocation(Plan plan, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageArrivalTime, long stageDeadline, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) throws PlanningException
PlanningException
public IterativePlanner setAlgStageEarliestStart(StageEarliestStart alg)
public IterativePlanner setAlgStageAllocator(StageAllocator alg)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.