@InterfaceAudience.Private @InterfaceStability.Unstable public class FiCaSchedulerApp extends SchedulerApplicationAttempt
SchedulerApplicationAttempt.ContainersAndNMTokensAllocation
appSchedulingInfo, attemptId, currentConsumption, currentReservation, isStopped, lastMemoryAggregateAllocationUpdateTime, lastScheduledContainer, liveContainers, newlyAllocatedContainers, queue, reservedContainers, rmContext
Constructor and Description |
---|
FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager,
RMContext rmContext) |
Modifier and Type | Method and Description |
---|---|
void |
addPreemptContainer(org.apache.hadoop.yarn.api.records.ContainerId cont) |
RMContainer |
allocate(NodeType type,
FiCaSchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority,
org.apache.hadoop.yarn.api.records.ResourceRequest request,
org.apache.hadoop.yarn.api.records.Container container) |
boolean |
containerCompleted(RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus,
RMContainerEventType event) |
Allocation |
getAllocation(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumAllocation)
This method produces an Allocation that includes the current view
of the resources that will be allocated to and preempted from this
application.
|
org.apache.hadoop.yarn.api.records.Resource |
getHeadroom()
Get available headroom in terms of resources for the application's user.
|
CapacityHeadroomProvider |
getHeadroomProvider() |
float |
getLocalityWaitFactor(org.apache.hadoop.yarn.api.records.Priority priority,
int clusterNodes) |
org.apache.hadoop.yarn.api.records.NodeId |
getNodeIdToUnreserve(org.apache.hadoop.yarn.api.records.Priority priority,
org.apache.hadoop.yarn.api.records.Resource capability) |
org.apache.hadoop.yarn.api.records.Resource |
getTotalPendingRequests() |
void |
setHeadroomProvider(CapacityHeadroomProvider headroomProvider) |
void |
transferStateFromPreviousAttempt(SchedulerApplicationAttempt appAttempt) |
boolean |
unreserve(FiCaSchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority) |
addReReservation, addSchedulingOpportunity, containerLaunchedOnNode, getAMResource, getApplicationAttemptId, getApplicationId, getAppSchedulingInfo, getCurrentConsumption, getCurrentReservation, getLastScheduledContainer, getLiveContainers, getLiveContainersMap, getNewContainerId, getNumReservedContainers, getPendingRelease, getPriorities, getQueue, getQueueName, getReReservations, getReservedContainers, getResource, getResourceLimit, getResourceRequest, getResourceRequests, getResourceUsageReport, getRMContainer, getSchedulingOpportunities, getTotalRequiredResources, getUnmanagedAM, getUser, incNumAllocatedContainers, isAmRunning, isBlacklisted, isBlacklisted, isPending, isReserved, isStopped, move, pullNewlyAllocatedContainersAndNMTokens, recoverContainer, recoverResourceRequests, reserve, resetReReservations, resetSchedulingOpportunities, resetSchedulingOpportunities, setAMResource, setAmRunning, setApplicationHeadroomForMetrics, setHeadroom, showRequests, stop, subtractSchedulingOpportunity, updateBlacklist, updateResourceRequests
public FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, String user, Queue queue, ActiveUsersManager activeUsersManager, RMContext rmContext)
public boolean containerCompleted(RMContainer rmContainer, org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus, RMContainerEventType event)
public RMContainer allocate(NodeType type, FiCaSchedulerNode node, org.apache.hadoop.yarn.api.records.Priority priority, org.apache.hadoop.yarn.api.records.ResourceRequest request, org.apache.hadoop.yarn.api.records.Container container)
public boolean unreserve(FiCaSchedulerNode node, org.apache.hadoop.yarn.api.records.Priority priority)
public float getLocalityWaitFactor(org.apache.hadoop.yarn.api.records.Priority priority, int clusterNodes)
public org.apache.hadoop.yarn.api.records.Resource getTotalPendingRequests()
public void addPreemptContainer(org.apache.hadoop.yarn.api.records.ContainerId cont)
public Allocation getAllocation(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, org.apache.hadoop.yarn.api.records.Resource clusterResource, org.apache.hadoop.yarn.api.records.Resource minimumAllocation)
rc
- clusterResource
- minimumAllocation
- public org.apache.hadoop.yarn.api.records.NodeId getNodeIdToUnreserve(org.apache.hadoop.yarn.api.records.Priority priority, org.apache.hadoop.yarn.api.records.Resource capability)
public void setHeadroomProvider(CapacityHeadroomProvider headroomProvider)
public CapacityHeadroomProvider getHeadroomProvider()
public org.apache.hadoop.yarn.api.records.Resource getHeadroom()
SchedulerApplicationAttempt
getHeadroom
in class SchedulerApplicationAttempt
public void transferStateFromPreviousAttempt(SchedulerApplicationAttempt appAttempt)
transferStateFromPreviousAttempt
in class SchedulerApplicationAttempt
Copyright © 2015 Apache Software Foundation. All Rights Reserved.