Package org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo

Class FifoAppAttempt

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplicationAttempt

org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerApp

org.apache.hadoop.yarn.server.resourcemanager.scheduler.fifo.FifoAppAttempt

All Implemented Interfaces:

SchedulableEntity

public class FifoAppAttempt
extends FiCaSchedulerApp

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplicationAttempt

SchedulerApplicationAttempt.AMState

Field Summary

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplicationAttempt

appAMNodePartitionName, appSchedulingInfo, attemptId, attemptOpportunisticResourceUsage, attemptResourceUsage, attemptResourceUsageAllocatedRemotely, isStopped, lastMemoryAggregateAllocationUpdateTime, lastScheduledContainer, liveContainers, newlyAllocatedContainers, newlyDecreasedContainers, newlyDemotedContainers, newlyIncreasedContainers, newlyPromotedContainers, queue, readLock, reservedContainers, rmContext, tempContainerToKill, updateContainerErrors, updatedNMTokens, writeLock

Method Summary

Modifier and Type	Method	Description
RMContainer	allocate(NodeType type, FiCaSchedulerNode node, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, org.apache.hadoop.yarn.api.records.Container container)

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerApp

accept, addToBeRemovedIncreaseRequest, allocate, apply, assignContainers, containerCompleted, equals, findNodeToUnreserve, getActivedAppDiagnosticMessage, getAllocation, getAppPlacementAllocator, getCSLeafQueue, getHeadroom, getNodeIdToUnreserve, getPendingAppDiagnosticMessage, getResourceUsageReport, getTotalPendingRequestsPerPartition, getWriteLock, hashCode, isRunnable, markContainerForPreemption, moveReservation, nodePartitionUpdated, reserve, setHeadroomProvider, setRunnable, transferStateFromPreviousAttempt, unreserve, updateAppSkipNodeDiagnostics, updateNodeInfoForAMDiagnostics

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplicationAttempt

addMissedNonPartitionedRequestSchedulingOpportunity, addReReservation, addRMContainer, addSchedulingOpportunity, addToNewlyAllocatedContainers, addToNewlyDecreasedContainers, addToNewlyDemotedContainers, addToUpdateContainerErrors, compareInputOrderTo, containerLaunchedOnNode, decUnconfirmedRes, getAMResource, getAMResource, getAppAMNodePartitionName, getAppAttemptResourceUsage, getApplicationAttemptId, getApplicationId, getApplicationSchedulingEnvs, getAppSchedulingInfo, getBlacklistedNodes, getCurrentConsumption, getCurrentReservation, getId, getLastScheduledContainer, getLiveContainers, getLiveContainersMap, getNewContainerId, getNumReservedContainers, getOpportunisticContainerContext, getOutstandingAsksCount, getOutstandingAsksCount, getPartition, getPendingAsk, getPendingRelease, getPriority, getQueue, getQueueName, getReReservations, getReservedContainers, getRMContainer, getSchedulerKeys, getSchedulingOpportunities, getSchedulingResourceUsage, getStartTime, getUnmanagedAM, getUpdateContext, getUser, hasPendingResourceRequest, incNumAllocatedContainers, incUnconfirmedRes, isAmRunning, isPending, isPlaceBlacklisted, isRecovering, isStopped, isWaitingForAMContainer, move, pullNewlyAllocatedContainers, pullNewlyDecreasedContainers, pullNewlyDemotedContainers, pullNewlyIncreasedContainers, pullNewlyPromotedContainers, pullPreviousAttemptContainers, pullUpdateContainerErrors, pullUpdatedNMTokens, recordContainerAllocationTime, recordContainerRequestTime, recoverContainer, recoverResourceRequestsForContainer, removeRMContainer, reserve, reserveIncreasedContainer, resetMissedNonPartitionedRequestSchedulingOpportunity, resetReReservations, resetSchedulingOpportunities, resetSchedulingOpportunities, setAMResource, setAMResource, setAmRunning, setAppAMNodePartitionName, setApplicationHeadroomForMetrics, setAttemptRecovering, setHeadroom, setOpportunisticContainerContext, setPriority, showRequests, stop, subtractSchedulingOpportunity, updateAMContainerDiagnostics, updateBlacklist, updateNMTokens, updateResourceRequests, updateSchedulingRequests

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Method Details

allocate

public RMContainer allocate(NodeType type,
 FiCaSchedulerNode node,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 org.apache.hadoop.yarn.api.records.Container container)