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

Class StageEarliestStartByDemand

java.lang.Object

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

All Implemented Interfaces:

StageEarliestStart

public class StageEarliestStartByDemand
extends Object
implements StageEarliestStart

Sets the earliest start time of a stage proportional to the job weight. The interval [jobArrival, stageDeadline) is divided as follows. First, each stage is guaranteed at least its requested duration. Then, the stage receives a fraction of the remaining time. The fraction is calculated as the ratio between the weight (total requested resources) of the stage and the total weight of all proceeding stages.

Constructor Summary

Constructors

Constructor and Description
StageEarliestStartByDemand()

Method Summary

Methods

Modifier and Type	Method and Description
protected double	calcWeight(org.apache.hadoop.yarn.api.records.ReservationRequest stage)
protected long	getRoundedDuration(org.apache.hadoop.yarn.api.records.ReservationRequest stage, Plan plan)
long	setEarliestStartTime(Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation, int index, org.apache.hadoop.yarn.api.records.ReservationRequest current, long stageDeadline) Computes the earliest allowed starting time for a given stage.
protected static long	stepRoundDown(long t, long step)
protected static long	stepRoundUp(long t, long step)

Methods inherited from class java.lang.Object

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

Constructor Detail

StageEarliestStartByDemand

public StageEarliestStartByDemand()

Method Detail

setEarliestStartTime

public long setEarliestStartTime(Plan plan,
                        org.apache.hadoop.yarn.api.records.ReservationDefinition reservation,
                        int index,
                        org.apache.hadoop.yarn.api.records.ReservationRequest current,
                        long stageDeadline)

Description copied from interface: StageEarliestStart

Computes the earliest allowed starting time for a given stage.

Specified by:

setEarliestStartTime in interface StageEarliestStart

Parameters:

plan - the Plan to which the reservation must be fitted

reservation - the job contract

index - the index of the stage in the job contract

current - the stage

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

Returns:

the earliest allowed starting time for the stage.

calcWeight

protected double calcWeight(org.apache.hadoop.yarn.api.records.ReservationRequest stage)

getRoundedDuration

protected long getRoundedDuration(org.apache.hadoop.yarn.api.records.ReservationRequest stage,
                      Plan plan)

stepRoundDown

protected static long stepRoundDown(long t,
                 long step)

stepRoundUp

protected static long stepRoundUp(long t,
               long step)