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 all the RMActiveService contexts.This is expected to be used only by ResourceManager and 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()
NodesListManager	getNodesListManager()
PlacementManager	getQueuePlacementManager()
ReservationSystem	getReservationSystem()
ResourceTrackerService	getResourceTrackerService()
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	setNodeLabelManager(RMNodeLabelsManager mgr)
void	setQueuePlacementManager(PlacementManager placementMgr)
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)