org.apache.hadoop.yarn.server.resourcemanager

Class RMActiveServiceContext

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.RMActiveServiceContext

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public class RMActiveServiceContext
extends Object

The RMActiveServiceContext is the class that maintains Active service context. Services that need to run only on the Active RM. This is expected to be used only by RMContext.

Constructor Summary

Constructors

Constructor and Description
RMActiveServiceContext()
RMActiveServiceContext(org.apache.hadoop.yarn.event.Dispatcher rmDispatcher, ContainerAllocationExpirer containerAllocationExpirer, AMLivelinessMonitor amLivelinessMonitor, AMLivelinessMonitor amFinishingMonitor, DelegationTokenRenewer delegationTokenRenewer, AMRMTokenSecretManager appTokenSecretManager, RMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInRM nmTokenSecretManager, ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager, ResourceScheduler scheduler)

Method Summary

Modifier and Type	Method and Description
AllocationTagsManager	getAllocationTagsManager()
AMLivelinessMonitor	getAMFinishingMonitor()
AMLivelinessMonitor	getAMLivelinessMonitor()
AMRMTokenSecretManager	getAMRMTokenSecretManager()
ApplicationMasterService	getApplicationMasterService()
ClientRMService	getClientRMService()
ClientToAMTokenSecretManagerInRM	getClientToAMTokenSecretManager()
ContainerAllocationExpirer	getContainerAllocationExpirer()
RMContainerTokenSecretManager	getContainerTokenSecretManager()
DelegationTokenRenewer	getDelegationTokenRenewer()
long	getEpoch()
ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode>	getInactiveRMNodes()
MultiNodeSortingManager<SchedulerNode>	getMultiNodeSortingManager()
NMTokenSecretManagerInRM	getNMTokenSecretManager()
org.apache.hadoop.yarn.nodelabels.NodeAttributesManager	getNodeAttributesManager()
RMNodeLabelsManager	getNodeLabelManager()
QueueLimitCalculator	getNodeManagerQueueLimitCalculator()
NodesListManager	getNodesListManager()
PlacementConstraintManager	getPlacementConstraintManager()
ProxyCAManager	getProxyCAManager()
PlacementManager	getQueuePlacementManager()
ReservationSystem	getReservationSystem()
ResourceProfilesManager	getResourceProfilesManager()
ResourceTrackerService	getResourceTrackerService()
RMAppLifetimeMonitor	getRMAppLifetimeMonitor()
ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,RMApp>	getRMApps()
RMDelegatedNodeLabelsUpdater	getRMDelegatedNodeLabelsUpdater()
RMDelegationTokenSecretManager	getRMDelegationTokenSecretManager()
ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode>	getRMNodes()
ResourceScheduler	getScheduler()
RMStateStore	getStateStore()
ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.SystemCredentialsForAppsProto>	getSystemCredentialsForApps()
Long	getTokenSequenceNo() Get token sequence no.
VolumeManager	getVolumeManager()
void	incrTokenSequenceNo() Increment token sequence no.
boolean	isSchedulerReadyForAllocatingContainers()
boolean	isWorkPreservingRecoveryEnabled()
void	setAllocationTagsManager(AllocationTagsManager allocationTagsManager)
void	setClientRMService(ClientRMService clientRMService)
void	setContainerQueueLimitCalculator(QueueLimitCalculator limitCalculator)
void	setMultiNodeSortingManager(MultiNodeSortingManager<SchedulerNode> multiNodeSortingManager)
void	setNodeAttributesManager(org.apache.hadoop.yarn.nodelabels.NodeAttributesManager mgr)
void	setNodeLabelManager(RMNodeLabelsManager mgr)
void	setPlacementConstraintManager(PlacementConstraintManager placementConstraintManager)
void	setProxyCAManager(ProxyCAManager proxyCAManager)
void	setQueuePlacementManager(PlacementManager placementMgr)
void	setResourceProfilesManager(ResourceProfilesManager resourceProfilesManager)
void	setRMAppLifetimeMonitor(RMAppLifetimeMonitor lifetimeMonitor)
void	setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater nodeLablesUpdater)
void	setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)
void	setSchedulerRecoveryStartAndWaitTime(long waitTime)
void	setStateStore(RMStateStore store)
void	setSystemClock(org.apache.hadoop.yarn.util.Clock clock)
void	setVolumeManager(VolumeManager volumeManager)
void	setWorkPreservingRecoveryEnabled(boolean enabled)

Methods inherited from class java.lang.Object

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

Constructor Detail

RMActiveServiceContext

public RMActiveServiceContext()

RMActiveServiceContext

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMActiveServiceContext(org.apache.hadoop.yarn.event.Dispatcher rmDispatcher,
                                                                                       ContainerAllocationExpirer containerAllocationExpirer,
                                                                                       AMLivelinessMonitor amLivelinessMonitor,
                                                                                       AMLivelinessMonitor amFinishingMonitor,
                                                                                       DelegationTokenRenewer delegationTokenRenewer,
                                                                                       AMRMTokenSecretManager appTokenSecretManager,
                                                                                       RMContainerTokenSecretManager containerTokenSecretManager,
                                                                                       NMTokenSecretManagerInRM nmTokenSecretManager,
                                                                                       ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager,
                                                                                       ResourceScheduler scheduler)

Method Detail

setStateStore

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setStateStore(RMStateStore store)

getClientRMService

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ClientRMService getClientRMService()

getApplicationMasterService

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ApplicationMasterService getApplicationMasterService()

getResourceTrackerService

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ResourceTrackerService getResourceTrackerService()

getStateStore

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMStateStore getStateStore()

getRMApps

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,RMApp> getRMApps()

getRMNodes

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> getRMNodes()

getInactiveRMNodes

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> getInactiveRMNodes()

getContainerAllocationExpirer

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ContainerAllocationExpirer getContainerAllocationExpirer()

getAMLivelinessMonitor

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public AMLivelinessMonitor getAMLivelinessMonitor()

getAMFinishingMonitor

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public AMLivelinessMonitor getAMFinishingMonitor()

getDelegationTokenRenewer

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public DelegationTokenRenewer getDelegationTokenRenewer()

getAMRMTokenSecretManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public AMRMTokenSecretManager getAMRMTokenSecretManager()

getContainerTokenSecretManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMContainerTokenSecretManager getContainerTokenSecretManager()

getNMTokenSecretManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public NMTokenSecretManagerInRM getNMTokenSecretManager()

getScheduler

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ResourceScheduler getScheduler()

getReservationSystem

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ReservationSystem getReservationSystem()

getNodesListManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public NodesListManager getNodesListManager()

getClientToAMTokenSecretManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ClientToAMTokenSecretManagerInRM getClientToAMTokenSecretManager()

setClientRMService

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setClientRMService(ClientRMService clientRMService)

getRMDelegationTokenSecretManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMDelegationTokenSecretManager getRMDelegationTokenSecretManager()

setRMDelegationTokenSecretManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)

setWorkPreservingRecoveryEnabled

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setWorkPreservingRecoveryEnabled(boolean enabled)

isWorkPreservingRecoveryEnabled

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public boolean isWorkPreservingRecoveryEnabled()

getEpoch

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public long getEpoch()

getNodeLabelManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMNodeLabelsManager getNodeLabelManager()

setNodeLabelManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setNodeLabelManager(RMNodeLabelsManager mgr)

getNodeAttributesManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public org.apache.hadoop.yarn.nodelabels.NodeAttributesManager getNodeAttributesManager()

setNodeAttributesManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setNodeAttributesManager(org.apache.hadoop.yarn.nodelabels.NodeAttributesManager mgr)

getAllocationTagsManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public AllocationTagsManager getAllocationTagsManager()

setAllocationTagsManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setAllocationTagsManager(AllocationTagsManager allocationTagsManager)

getPlacementConstraintManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public PlacementConstraintManager getPlacementConstraintManager()

setPlacementConstraintManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setPlacementConstraintManager(PlacementConstraintManager placementConstraintManager)

getRMDelegatedNodeLabelsUpdater

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMDelegatedNodeLabelsUpdater getRMDelegatedNodeLabelsUpdater()

setRMDelegatedNodeLabelsUpdater

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater nodeLablesUpdater)

getMultiNodeSortingManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public MultiNodeSortingManager<SchedulerNode> getMultiNodeSortingManager()

setMultiNodeSortingManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setMultiNodeSortingManager(MultiNodeSortingManager<SchedulerNode> multiNodeSortingManager)

setSchedulerRecoveryStartAndWaitTime

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setSchedulerRecoveryStartAndWaitTime(long waitTime)

isSchedulerReadyForAllocatingContainers

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public boolean isSchedulerReadyForAllocatingContainers()

setSystemClock

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setSystemClock(org.apache.hadoop.yarn.util.Clock clock)

getSystemCredentialsForApps

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.SystemCredentialsForAppsProto> getSystemCredentialsForApps()

getQueuePlacementManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public PlacementManager getQueuePlacementManager()

setQueuePlacementManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setQueuePlacementManager(PlacementManager placementMgr)

setRMAppLifetimeMonitor

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setRMAppLifetimeMonitor(RMAppLifetimeMonitor lifetimeMonitor)

getRMAppLifetimeMonitor

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public RMAppLifetimeMonitor getRMAppLifetimeMonitor()

getNodeManagerQueueLimitCalculator

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public QueueLimitCalculator getNodeManagerQueueLimitCalculator()

setContainerQueueLimitCalculator

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setContainerQueueLimitCalculator(QueueLimitCalculator limitCalculator)

getResourceProfilesManager

public ResourceProfilesManager getResourceProfilesManager()

setResourceProfilesManager

public void setResourceProfilesManager(ResourceProfilesManager resourceProfilesManager)

getProxyCAManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public ProxyCAManager getProxyCAManager()

setProxyCAManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setProxyCAManager(ProxyCAManager proxyCAManager)

getVolumeManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public VolumeManager getVolumeManager()

setVolumeManager

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public void setVolumeManager(VolumeManager volumeManager)

getTokenSequenceNo

public Long getTokenSequenceNo()

Get token sequence no.

Returns:

the tokenSequenceNo

incrTokenSequenceNo

public void incrTokenSequenceNo()

Increment token sequence no.