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

Class StageExecutionIntervalUnconstrained

java.lang.Object

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

All Implemented Interfaces:

StageExecutionInterval

public class StageExecutionIntervalUnconstrained
extends Object
implements StageExecutionInterval

An implementation of StageExecutionInterval which gives each stage the maximal possible time interval, given the job constraints. Specifically, for ANY and ALL jobs, the interval would be [jobArrival, jobDeadline). For ORDER jobs, the stage cannot start before its predecessors (if allocateLeft == true) or cannot end before its successors (if allocateLeft == false)

Constructor Summary

Constructors

Constructor	Description
StageExecutionIntervalUnconstrained()

Method Summary

Modifier and Type	Method	Description
ReservationInterval	computeExecutionInterval(Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation, org.apache.hadoop.yarn.api.records.ReservationRequest currentReservationStage, boolean allocateLeft, RLESparseResourceAllocation allocations)	Computes the earliest allowed starting time for a given stage.

Methods inherited from class java.lang.Object

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

Constructor Details

StageExecutionIntervalUnconstrained

public StageExecutionIntervalUnconstrained()

Method Details

computeExecutionInterval

public ReservationInterval computeExecutionInterval(Plan plan,
 org.apache.hadoop.yarn.api.records.ReservationDefinition reservation,
 org.apache.hadoop.yarn.api.records.ReservationRequest currentReservationStage,
 boolean allocateLeft,
 RLESparseResourceAllocation allocations)

Description copied from interface: StageExecutionInterval

Computes the earliest allowed starting time for a given stage.

Specified by:

computeExecutionInterval in interface StageExecutionInterval

Parameters:

plan - the Plan to which the reservation must be fitted

reservation - the job contract

currentReservationStage - the stage

allocateLeft - is the job allocated from left to right

allocations - Existing resource assignments for the job

Returns:

the time interval in which the stage can get resources.