Package | Description |
---|---|
org.apache.hadoop.yarn.server.resourcemanager.reservation | |
org.apache.hadoop.yarn.server.resourcemanager.reservation.planning |
Modifier and Type | Method and Description |
---|---|
RLESparseResourceAllocation |
SharingPolicy.availableResources(RLESparseResourceAllocation available,
Plan plan,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end)
This method provide a (partial) instantaneous validation by applying
business rules (such as max number of parallel containers allowed for a
user).
|
RLESparseResourceAllocation |
NoOverCommitPolicy.availableResources(RLESparseResourceAllocation available,
Plan plan,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end) |
RLESparseResourceAllocation |
CapacityOverTimePolicy.availableResources(RLESparseResourceAllocation available,
Plan plan,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end) |
RLESparseResourceAllocation |
PlanView.getAvailableResourceOverTime(String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end)
This method returns the amount of resources available to a given user
(optionally if removing a certain reservation) over the start-end time
range.
|
RLESparseResourceAllocation |
InMemoryPlan.getAvailableResourceOverTime(String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end) |
RLESparseResourceAllocation |
PlanView.getConsumptionForUserOverTime(String user,
long start,
long end)
This method returns a RLE encoded view of the user reservation utilization
between start and end time.
|
RLESparseResourceAllocation |
InMemoryPlan.getConsumptionForUserOverTime(String user,
long start,
long end) |
RLESparseResourceAllocation |
RLESparseResourceAllocation.getRangeOverlapping(long start,
long end) |
RLESparseResourceAllocation |
PlanView.getReservationCountForUserOverTime(String user,
long start,
long end)
This method returns a RLE encoded view of the user reservation count
utilization between start and end time.
|
RLESparseResourceAllocation |
InMemoryPlan.getReservationCountForUserOverTime(String user,
long start,
long end) |
RLESparseResourceAllocation |
ReservationAllocation.getResourcesOverTime()
Return a RLE representation of used resources.
|
RLESparseResourceAllocation |
InMemoryReservationAllocation.getResourcesOverTime() |
static RLESparseResourceAllocation |
RLESparseResourceAllocation.merge(org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
RLESparseResourceAllocation a,
RLESparseResourceAllocation b,
RLESparseResourceAllocation.RLEOperator operator,
long start,
long end)
Merges the range start to end of two
RLESparseResourceAllocation
using a given RLEOperator . |
Modifier and Type | Method and Description |
---|---|
RLESparseResourceAllocation |
SharingPolicy.availableResources(RLESparseResourceAllocation available,
Plan plan,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end)
This method provide a (partial) instantaneous validation by applying
business rules (such as max number of parallel containers allowed for a
user).
|
RLESparseResourceAllocation |
NoOverCommitPolicy.availableResources(RLESparseResourceAllocation available,
Plan plan,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end) |
RLESparseResourceAllocation |
CapacityOverTimePolicy.availableResources(RLESparseResourceAllocation available,
Plan plan,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId,
long start,
long end) |
static RLESparseResourceAllocation |
RLESparseResourceAllocation.merge(org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
RLESparseResourceAllocation a,
RLESparseResourceAllocation b,
RLESparseResourceAllocation.RLEOperator operator,
long start,
long end)
Merges the range start to end of two
RLESparseResourceAllocation
using a given RLEOperator . |
Modifier and Type | Method and Description |
---|---|
abstract RLESparseResourceAllocation |
PlanningAlgorithm.computeJobAllocation(Plan plan,
org.apache.hadoop.yarn.api.records.ReservationId reservationId,
org.apache.hadoop.yarn.api.records.ReservationDefinition reservation,
String user) |
RLESparseResourceAllocation |
IterativePlanner.computeJobAllocation(Plan plan,
org.apache.hadoop.yarn.api.records.ReservationId reservationId,
org.apache.hadoop.yarn.api.records.ReservationDefinition reservation,
String user) |
Modifier and Type | Method and Description |
---|---|
protected double |
StageAllocatorLowCostAligned.calcCostOfInterval(long startTime,
long endTime,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.Resource capacity,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc,
long step) |
protected double |
StageAllocatorLowCostAligned.calcCostOfTimeSlot(long t,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.Resource capacity,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc) |
Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> |
StageAllocatorLowCostAligned.computeStageAllocation(Plan plan,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.ReservationRequest rr,
long stageEarliestStart,
long stageDeadline,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId) |
Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> |
StageAllocatorGreedyRLE.computeStageAllocation(Plan plan,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.ReservationRequest rr,
long stageEarliestStart,
long stageDeadline,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId) |
Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> |
StageAllocatorGreedy.computeStageAllocation(Plan plan,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.ReservationRequest rr,
long stageEarliestStart,
long stageDeadline,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId) |
Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> |
StageAllocator.computeStageAllocation(Plan plan,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.ReservationRequest rr,
long stageEarliestStart,
long stageDeadline,
String user,
org.apache.hadoop.yarn.api.records.ReservationId oldId)
Computes the allocation of a stage inside a defined time interval.
|
protected StageAllocatorLowCostAligned.DurationInterval |
StageAllocatorLowCostAligned.getDurationInterval(long startTime,
long endTime,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications,
org.apache.hadoop.yarn.api.records.Resource capacity,
org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc,
long step) |
protected org.apache.hadoop.yarn.api.records.Resource |
StageAllocatorLowCostAligned.getLoadAtTime(long t,
Map<Long,org.apache.hadoop.yarn.api.records.Resource> planLoads,
RLESparseResourceAllocation planModifications) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.