public interface PlanView extends PlanContext
ReservationAgent
s to
determine the free resources in a certain point in time, and by
PlanFollowerPolicy to publish this plan to the scheduler.Modifier and Type | Method and Description |
---|---|
Set<ReservationAllocation> |
getAllReservations()
Gets all the reservations in the plan
|
org.apache.hadoop.yarn.api.records.Resource |
getConsumptionForUser(String user,
long tick)
Returns the total
Resource reserved for a given user at the
specified time |
long |
getEarliestStartTime()
Gets the time (UTC in ms) at which the first reservation starts
|
long |
getLastEndTime()
Returns the time (UTC in ms) at which the last reservation terminates
|
ReservationAllocation |
getReservationById(org.apache.hadoop.yarn.api.records.ReservationId reservationID)
Return a
ReservationAllocation identified by its
ReservationId |
Set<ReservationAllocation> |
getReservationsAtTime(long tick)
Gets all the active reservations at the specified point of time
|
org.apache.hadoop.yarn.api.records.Resource |
getTotalCapacity()
Returns the overall capacity in terms of
Resource assigned to this
plan (typically will correspond to the absolute capacity of the
corresponding queue). |
org.apache.hadoop.yarn.api.records.Resource |
getTotalCommittedResources(long tick)
Returns the total
Resource reserved for all users at the specified
time |
getMaximumAllocation, getMinimumAllocation, getMoveOnExpiry, getQueueMetrics, getQueueName, getReplanner, getReservationAgent, getResourceCalculator, getSharingPolicy, getStep
ReservationAllocation getReservationById(org.apache.hadoop.yarn.api.records.ReservationId reservationID)
ReservationAllocation
identified by its
ReservationId
reservationID
- the unique id to identify the
ReservationAllocation
ReservationAllocation
identified by the specified idSet<ReservationAllocation> getReservationsAtTime(long tick)
tick
- the time (UTC in ms) for which the active reservations are
requestedSet<ReservationAllocation> getAllReservations()
org.apache.hadoop.yarn.api.records.Resource getTotalCommittedResources(long tick)
Resource
reserved for all users at the specified
timetick
- the time (UTC in ms) for which the reserved resources are
requestedResource
reserved for all users at the specified
timeorg.apache.hadoop.yarn.api.records.Resource getConsumptionForUser(String user, long tick)
Resource
reserved for a given user at the
specified timeuser
- the user who made the reservation(s)tick
- the time (UTC in ms) for which the reserved resources are
requestedResource
reserved for a given user at the
specified timeorg.apache.hadoop.yarn.api.records.Resource getTotalCapacity()
Resource
assigned to this
plan (typically will correspond to the absolute capacity of the
corresponding queue).Resource
assigned to this
planlong getEarliestStartTime()
long getLastEndTime()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.