Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.reservation | |
org.apache.hadoop.yarn.server.resourcemanager.reservation.exceptions |
Modifier and Type | Method and Description |
---|---|
boolean |
PlanEdit.addReservation(ReservationAllocation reservation)
Add a new
ReservationAllocation to the plan |
void |
PlanEdit.archiveCompletedReservations(long tick)
Method invoked to garbage collect old reservations.
|
boolean |
GreedyReservationAgent.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan,
org.apache.hadoop.yarn.api.records.ReservationDefinition contract) |
boolean |
ReservationAgent.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan,
org.apache.hadoop.yarn.api.records.ReservationDefinition contract)
Create a reservation for the user that abides by the specified contract
|
boolean |
PlanEdit.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationID)
Delete an existing
ReservationAllocation from the plan identified
uniquely by its ReservationId . |
boolean |
GreedyReservationAgent.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan) |
boolean |
ReservationAgent.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan)
Delete an user reservation
|
void |
SimpleCapacityReplanner.plan(Plan plan,
List<org.apache.hadoop.yarn.api.records.ReservationDefinition> contracts) |
void |
Planner.plan(Plan plan,
List<org.apache.hadoop.yarn.api.records.ReservationDefinition> contracts)
Update the existing
Plan , by adding/removing/updating existing
reservations, and adding a subset of the reservation requests in the
contracts parameter. |
boolean |
PlanEdit.updateReservation(ReservationAllocation reservation)
Updates an existing
ReservationAllocation in the plan. |
boolean |
GreedyReservationAgent.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan,
org.apache.hadoop.yarn.api.records.ReservationDefinition contract) |
boolean |
ReservationAgent.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId,
String user,
Plan plan,
org.apache.hadoop.yarn.api.records.ReservationDefinition contract)
Update a reservation for the user that abides by the specified contract
|
void |
CapacityOverTimePolicy.validate(Plan plan,
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) |
Modifier and Type | Class and Description |
---|---|
class |
ContractValidationException
This exception is thrown if the request made is not syntactically valid.
|
class |
MismatchedUserException
Exception thrown when an update to an existing reservation is performed
by a user that is not the reservation owner.
|
class |
PlanningQuotaException
This exception is thrown if the user quota is exceed while accepting or
updating a reservation.
|
class |
ResourceOverCommitException
This exception indicate that the reservation that has been attempted, would
exceed the physical resources available in the
Plan at the moment. |
Copyright © 2019 Apache Software Foundation. All Rights Reserved.