Package org.apache.hadoop.yarn.api.records

Class ReservationDefinition

java.lang.Object
org.apache.hadoop.yarn.api.records.ReservationDefinition
@Public @Unstable public abstract class ReservationDefinition extends Object
ReservationDefinition captures the set of resource and time constraints the user cares about regarding a reservation.
See Also:

  • Constructor Details

    • ReservationDefinition

      public ReservationDefinition()

  • Method Details

    • newInstance

      @Public @Unstable public static ReservationDefinition newInstance(long arrival, long deadline, ReservationRequests reservationRequests, String name, String recurrenceExpression, Priority priority)

    • newInstance

      @Public @Unstable public static ReservationDefinition newInstance(long arrival, long deadline, ReservationRequests reservationRequests, String name)

    • getArrival

      @Public @Unstable public abstract long getArrival()
      Get the arrival time or the earliest time from which the resource(s) can be allocated. Time expressed as UTC.
      Returns:
      the earliest valid time for this reservation

    • setArrival

      @Public @Unstable public abstract void setArrival(long earliestStartTime)
      Set the arrival time or the earliest time from which the resource(s) can be allocated. Time expressed as UTC.
      Parameters:
      earliestStartTime - the earliest valid time for this reservation

    • getDeadline

      @Public @Unstable public abstract long getDeadline()
      Get the deadline or the latest time by when the resource(s) must be allocated. Time expressed as UTC.
      Returns:
      the deadline or the latest time by when the resource(s) must be allocated

    • setDeadline

      @Public @Unstable public abstract void setDeadline(long latestEndTime)
      Set the deadline or the latest time by when the resource(s) must be allocated. Time expressed as UTC.
      Parameters:
      latestEndTime - the deadline or the latest time by when the resource(s) should be allocated

    • getReservationRequests

      @Public @Unstable public abstract ReservationRequests getReservationRequests()
      Get the list of ReservationRequests representing the resources required by the application
      Returns:
      the list of ReservationRequests

    • setReservationRequests

      @Public @Unstable public abstract void setReservationRequests(ReservationRequests reservationRequests)
      Set the list of ReservationRequests representing the resources required by the application
      Parameters:
      reservationRequests - the list of ReservationRequests

    • getReservationName

      @Public @Unstable public abstract String getReservationName()
      Get the name for this reservation. The name need-not be unique, and it is just a mnemonic for the user (akin to job names). Accepted reservations are uniquely identified by a system-generated ReservationId.
      Returns:
      string representing the name of the corresponding reserved resource allocation in the scheduler

    • setReservationName

      @Public @Unstable public abstract void setReservationName(String name)
      Set the name for this reservation. The name need-not be unique, and it is just a mnemonic for the user (akin to job names). Accepted reservations are uniquely identified by a system-generated ReservationId.
      Parameters:
      name - representing the name of the corresponding reserved resource allocation in the scheduler

    • getRecurrenceExpression

      @Public @Unstable public abstract String getRecurrenceExpression()
      Get the recurrence of this reservation representing the time period of the periodic job. Currently, only long values are supported. Later, support for regular expressions denoting arbitrary recurrence patterns (e.g., every Tuesday and Thursday) will be added. Recurrence is represented in milliseconds for periodic jobs. Recurrence is 0 for non-periodic jobs. Periodic jobs are valid until they are explicitly cancelled and have higher priority than non-periodic jobs (during initial placement and replanning). Periodic job allocations are consistent across runs (flexibility in allocation is leveraged only during initial placement, allocations remain consistent thereafter). Note that as a long, the recurrence expression must be greater than the duration of the reservation (deadline - arrival). Also note that the configured max period must be divisible by the recurrence expression if expressed as a long.
      Returns:
      recurrence of this reservation

    • setRecurrenceExpression

      @Public @Unstable public abstract void setRecurrenceExpression(String recurrenceExpression)
      Set the recurrence of this reservation representing the time period of the periodic job. Currently, only long values are supported. Later, support for regular expressions denoting arbitrary recurrence patterns (e.g., every Tuesday and Thursday) will be added. Recurrence is represented in milliseconds for periodic jobs. Recurrence is 0 for non-periodic jobs. Periodic jobs are valid until they are explicitly cancelled and have higher priority than non-periodic jobs (during initial placement and replanning). Periodic job allocations are consistent across runs (flexibility in allocation is leveraged only during initial placement, allocations remain consistent thereafter). Note that as a long, the recurrence expression must be greater than the duration of the reservation (deadline - arrival). Also note that the configured max period must be divisible by the recurrence expression if expressed as a long.
      Parameters:
      recurrenceExpression - recurrence interval of this reservation

    • getPriority

      @Public @Unstable public abstract Priority getPriority()
      Get the priority for this reservation. A lower number for priority indicates a higher priority reservation. Recurring reservations are always higher priority than non-recurring reservations. Priority for non-recurring reservations are only compared with non-recurring reservations. Likewise for recurring reservations.
      Returns:
      int representing the priority of the reserved resource allocation in the scheduler

    • setPriority

      @Public @Unstable public abstract void setPriority(Priority priority)
      Set the priority for this reservation. A lower number for priority indicates a higher priority reservation. Recurring reservations are always higher priority than non-recurring reservations. Priority for non-recurring reservations are only compared with non-recurring reservations. Likewise for recurring reservations.
      Parameters:
      priority - representing the priority of the reserved resource allocation in the scheduler