Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.reservation | |
org.apache.hadoop.yarn.server.resourcemanager.reservation.planning |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryReservationAllocation
An in memory implementation of a reservation allocation using the
RLESparseResourceAllocation |
Modifier and Type | Method and Description |
---|---|
ReservationAllocation |
PlanView.getReservationById(org.apache.hadoop.yarn.api.records.ReservationId reservationID)
Return a
ReservationAllocation identified by its
ReservationId |
ReservationAllocation |
InMemoryPlan.getReservationById(org.apache.hadoop.yarn.api.records.ReservationId reservationID) |
Modifier and Type | Method and Description |
---|---|
Set<ReservationAllocation> |
PlanView.getAllReservations()
Gets all the reservations in the plan
|
Set<ReservationAllocation> |
InMemoryPlan.getAllReservations() |
Set<ReservationAllocation> |
PlanView.getReservationByUserAtTime(String user,
long t)
Return a set of
ReservationAllocation that belongs to a certain
user and overlaps time t. |
Set<ReservationAllocation> |
InMemoryPlan.getReservationByUserAtTime(String user,
long t) |
Set<ReservationAllocation> |
PlanView.getReservations(org.apache.hadoop.yarn.api.records.ReservationId reservationID,
ReservationInterval interval)
Return a set of
ReservationAllocation identified by any user. |
Set<ReservationAllocation> |
InMemoryPlan.getReservations(org.apache.hadoop.yarn.api.records.ReservationId reservationID,
ReservationInterval interval) |
Set<ReservationAllocation> |
PlanView.getReservations(org.apache.hadoop.yarn.api.records.ReservationId reservationID,
ReservationInterval interval,
String user)
Return a set of
ReservationAllocation identified by the user who
made the reservation. |
Set<ReservationAllocation> |
InMemoryPlan.getReservations(org.apache.hadoop.yarn.api.records.ReservationId reservationID,
ReservationInterval interval,
String user) |
Set<ReservationAllocation> |
PlanView.getReservationsAtTime(long tick)
Gets all the active reservations at the specified point of time
|
Set<ReservationAllocation> |
InMemoryPlan.getReservationsAtTime(long tick) |
protected List<ReservationAllocation> |
AbstractSchedulerPlanFollower.sortByDelta(List<ReservationAllocation> currentReservations,
long now,
Plan plan)
Sort in the order from the least new amount of resources asked (likely
negative) to the highest.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PlanEdit.addReservation(ReservationAllocation reservation,
boolean isRecovering)
Add a new
ReservationAllocation to the plan |
boolean |
InMemoryPlan.addReservation(ReservationAllocation reservation,
boolean isRecovering) |
static org.apache.hadoop.yarn.proto.YarnProtos.ReservationAllocationStateProto |
ReservationSystemUtil.buildStateProto(ReservationAllocation allocation) |
int |
InMemoryReservationAllocation.compareTo(ReservationAllocation other) |
boolean |
PlanEdit.updateReservation(ReservationAllocation reservation)
Updates an existing
ReservationAllocation in the plan. |
boolean |
InMemoryPlan.updateReservation(ReservationAllocation reservation) |
void |
SharingPolicy.validate(Plan plan,
ReservationAllocation newAllocation)
This method runs the policy validation logic, and return true/false on
whether the
ReservationAllocation is acceptable according to this
sharing policy. |
void |
NoOverCommitPolicy.validate(Plan plan,
ReservationAllocation reservation) |
void |
CapacityOverTimePolicy.validate(Plan plan,
ReservationAllocation reservation) |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.yarn.api.records.ReservationAllocationState> |
ReservationSystemUtil.convertAllocationsToReservationInfo(Set<ReservationAllocation> res,
boolean includeResourceAllocations) |
protected int |
AbstractSchedulerPlanFollower.getReservedResources(long now,
Set<ReservationAllocation> currentReservations,
Set<String> curReservationNames,
org.apache.hadoop.yarn.api.records.Resource reservedResources) |
protected List<ReservationAllocation> |
AbstractSchedulerPlanFollower.sortByDelta(List<ReservationAllocation> currentReservations,
long now,
Plan plan)
Sort in the order from the least new amount of resources asked (likely
negative) to the highest.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
PlanningAlgorithm.allocateUser(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan,
org.apache.hadoop.yarn.api.records.ReservationDefinition contract,
ReservationAllocation oldReservation)
Performs the actual allocation for a ReservationDefinition within a Plan.
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.