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

Methods

Modifier and Type	Method and Description
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()
NMTokenSecretManagerInRM	getNMTokenSecretManager()
RMNodeLabelsManager	getNodeLabelManager()
QueueLimitCalculator	getNodeManagerQueueLimitCalculator()
NodesListManager	getNodesListManager()
PlacementManager	getQueuePlacementManager()
ReservationSystem	getReservationSystem()
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,ByteBuffer>	getSystemCredentialsForApps()
boolean	isSchedulerReadyForAllocatingContainers()
boolean	isWorkPreservingRecoveryEnabled()
void	setClientRMService(ClientRMService clientRMService)
void	setContainerQueueLimitCalculator(QueueLimitCalculator limitCalculator)
void	setNodeLabelManager(RMNodeLabelsManager mgr)
void	setQueuePlacementManager(PlacementManager placementMgr)
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	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)

getRMDelegatedNodeLabelsUpdater

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

setRMDelegatedNodeLabelsUpdater

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

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,ByteBuffer> 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)