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

Interface StageExecutionInterval

All Known Implementing Classes:
StageExecutionIntervalByDemand, StageExecutionIntervalUnconstrained
public interface StageExecutionInterval
An auxiliary class used to compute the time interval in which the stage can be allocated resources by IterativePlanner.

  • 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.

  • Method Details

    • computeExecutionInterval

      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.
      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.