org.apache.hadoop.yarn.server.resourcemanager

Class RMContextImpl

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.RMContextImpl

All Implemented Interfaces:

RMContext

public class RMContextImpl
extends Object
implements RMContext

Constructor Summary

Constructors

Constructor and Description
RMContextImpl() Default constructor.
RMContextImpl(org.apache.hadoop.yarn.event.Dispatcher rmDispatcher, ContainerAllocationExpirer containerAllocationExpirer, AMLivelinessMonitor amLivelinessMonitor, AMLivelinessMonitor amFinishingMonitor, DelegationTokenRenewer delegationTokenRenewer, AMRMTokenSecretManager appTokenSecretManager, RMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInRM nmTokenSecretManager, ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager)
RMContextImpl(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
RMActiveServiceContext	getActiveServiceContext()
AMLivelinessMonitor	getAMFinishingMonitor()
AMLivelinessMonitor	getAMLivelinessMonitor()
AMRMTokenSecretManager	getAMRMTokenSecretManager()
ApplicationMasterService	getApplicationMasterService()
ClientRMService	getClientRMService()
ClientToAMTokenSecretManagerInRM	getClientToAMTokenSecretManager()
org.apache.hadoop.yarn.conf.ConfigurationProvider	getConfigurationProvider()
ContainerAllocationExpirer	getContainerAllocationExpirer()
RMContainerTokenSecretManager	getContainerTokenSecretManager()
DelegationTokenRenewer	getDelegationTokenRenewer()
org.apache.hadoop.yarn.event.Dispatcher	getDispatcher()
long	getEpoch()
org.apache.hadoop.ha.HAServiceProtocol.HAServiceState	getHAServiceState()
String	getHAZookeeperConnectionState()
ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode>	getInactiveRMNodes()
EmbeddedElector	getLeaderElectorService()
NMTokenSecretManagerInRM	getNMTokenSecretManager()
RMNodeLabelsManager	getNodeLabelManager()
NodesListManager	getNodesListManager()
PlacementManager	getQueuePlacementManager()
ReservationSystem	getReservationSystem()
ResourceTrackerService	getResourceTrackerService()
AdminService	getRMAdminService()
RMApplicationHistoryWriter	getRMApplicationHistoryWriter()
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()
SystemMetricsPublisher	getSystemMetricsPublisher()
org.apache.hadoop.conf.Configuration	getYarnConfiguration()
boolean	isHAEnabled()
boolean	isSchedulerReadyForAllocatingContainers()
boolean	isWorkPreservingRecoveryEnabled()
void	setClientRMService(ClientRMService clientRMService)
void	setConfigurationProvider(org.apache.hadoop.yarn.conf.ConfigurationProvider configurationProvider)
void	setLeaderElectorService(EmbeddedElector elector)
void	setNodeLabelManager(RMNodeLabelsManager mgr)
void	setQueuePlacementManager(PlacementManager placementMgr)
void	setRMApplicationHistoryWriter(RMApplicationHistoryWriter rmApplicationHistoryWriter)
void	setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater delegatedNodeLabelsUpdater)
void	setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)
void	setScheduler(ResourceScheduler scheduler)
void	setSchedulerRecoveryStartAndWaitTime(long waitTime)
void	setStateStore(RMStateStore store)
void	setSystemClock(org.apache.hadoop.yarn.util.Clock clock)
void	setSystemMetricsPublisher(SystemMetricsPublisher systemMetricsPublisher)
void	setWorkPreservingRecoveryEnabled(boolean enabled)
void	setYarnConfiguration(org.apache.hadoop.conf.Configuration yarnConfiguration)

Methods inherited from class java.lang.Object

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

Constructor Detail

RMContextImpl

public RMContextImpl()

Default constructor. To be used in conjunction with setter methods for individual fields.

RMContextImpl

public RMContextImpl(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)

RMContextImpl

public RMContextImpl(org.apache.hadoop.yarn.event.Dispatcher rmDispatcher,
             ContainerAllocationExpirer containerAllocationExpirer,
             AMLivelinessMonitor amLivelinessMonitor,
             AMLivelinessMonitor amFinishingMonitor,
             DelegationTokenRenewer delegationTokenRenewer,
             AMRMTokenSecretManager appTokenSecretManager,
             RMContainerTokenSecretManager containerTokenSecretManager,
             NMTokenSecretManagerInRM nmTokenSecretManager,
             ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager)

Method Detail

getDispatcher

public org.apache.hadoop.yarn.event.Dispatcher getDispatcher()

Specified by:

getDispatcher in interface RMContext

setLeaderElectorService

public void setLeaderElectorService(EmbeddedElector elector)

Specified by:

setLeaderElectorService in interface RMContext

getLeaderElectorService

public EmbeddedElector getLeaderElectorService()

Specified by:

getLeaderElectorService in interface RMContext

getStateStore

public RMStateStore getStateStore()

Specified by:

getStateStore in interface RMContext

getRMApps

public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,RMApp> getRMApps()

Specified by:

getRMApps in interface RMContext

getRMNodes

public ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> getRMNodes()

Specified by:

getRMNodes in interface RMContext

getInactiveRMNodes

public ConcurrentMap<org.apache.hadoop.yarn.api.records.NodeId,RMNode> getInactiveRMNodes()

Specified by:

getInactiveRMNodes in interface RMContext

getContainerAllocationExpirer

public ContainerAllocationExpirer getContainerAllocationExpirer()

Specified by:

getContainerAllocationExpirer in interface RMContext

getAMLivelinessMonitor

public AMLivelinessMonitor getAMLivelinessMonitor()

Specified by:

getAMLivelinessMonitor in interface RMContext

getAMFinishingMonitor

public AMLivelinessMonitor getAMFinishingMonitor()

Specified by:

getAMFinishingMonitor in interface RMContext

getDelegationTokenRenewer

public DelegationTokenRenewer getDelegationTokenRenewer()

Specified by:

getDelegationTokenRenewer in interface RMContext

getAMRMTokenSecretManager

public AMRMTokenSecretManager getAMRMTokenSecretManager()

Specified by:

getAMRMTokenSecretManager in interface RMContext

getContainerTokenSecretManager

public RMContainerTokenSecretManager getContainerTokenSecretManager()

Specified by:

getContainerTokenSecretManager in interface RMContext

getNMTokenSecretManager

public NMTokenSecretManagerInRM getNMTokenSecretManager()

Specified by:

getNMTokenSecretManager in interface RMContext

getScheduler

public ResourceScheduler getScheduler()

Specified by:

getScheduler in interface RMContext

getReservationSystem

public ReservationSystem getReservationSystem()

Specified by:

getReservationSystem in interface RMContext

getNodesListManager

public NodesListManager getNodesListManager()

Specified by:

getNodesListManager in interface RMContext

getClientToAMTokenSecretManager

public ClientToAMTokenSecretManagerInRM getClientToAMTokenSecretManager()

Specified by:

getClientToAMTokenSecretManager in interface RMContext

getRMAdminService

public AdminService getRMAdminService()

Specified by:

getRMAdminService in interface RMContext

setStateStore

public void setStateStore(RMStateStore store)

getClientRMService

public ClientRMService getClientRMService()

Specified by:

getClientRMService in interface RMContext

getApplicationMasterService

public ApplicationMasterService getApplicationMasterService()

Specified by:

getApplicationMasterService in interface RMContext

getResourceTrackerService

public ResourceTrackerService getResourceTrackerService()

Specified by:

getResourceTrackerService in interface RMContext

setClientRMService

public void setClientRMService(ClientRMService clientRMService)

Specified by:

setClientRMService in interface RMContext

getRMDelegationTokenSecretManager

public RMDelegationTokenSecretManager getRMDelegationTokenSecretManager()

Specified by:

getRMDelegationTokenSecretManager in interface RMContext

setRMDelegationTokenSecretManager

public void setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)

Specified by:

setRMDelegationTokenSecretManager in interface RMContext

setScheduler

public void setScheduler(ResourceScheduler scheduler)

isHAEnabled

public boolean isHAEnabled()

Specified by:

isHAEnabled in interface RMContext

getHAServiceState

public org.apache.hadoop.ha.HAServiceProtocol.HAServiceState getHAServiceState()

Specified by:

getHAServiceState in interface RMContext

setWorkPreservingRecoveryEnabled

public void setWorkPreservingRecoveryEnabled(boolean enabled)

isWorkPreservingRecoveryEnabled

public boolean isWorkPreservingRecoveryEnabled()

Specified by:

isWorkPreservingRecoveryEnabled in interface RMContext

getRMApplicationHistoryWriter

public RMApplicationHistoryWriter getRMApplicationHistoryWriter()

Specified by:

getRMApplicationHistoryWriter in interface RMContext

setSystemMetricsPublisher

public void setSystemMetricsPublisher(SystemMetricsPublisher systemMetricsPublisher)

Specified by:

setSystemMetricsPublisher in interface RMContext

getSystemMetricsPublisher

public SystemMetricsPublisher getSystemMetricsPublisher()

Specified by:

getSystemMetricsPublisher in interface RMContext

setRMApplicationHistoryWriter

public void setRMApplicationHistoryWriter(RMApplicationHistoryWriter rmApplicationHistoryWriter)

Specified by:

setRMApplicationHistoryWriter in interface RMContext

getConfigurationProvider

public org.apache.hadoop.yarn.conf.ConfigurationProvider getConfigurationProvider()

Specified by:

getConfigurationProvider in interface RMContext

setConfigurationProvider

public void setConfigurationProvider(org.apache.hadoop.yarn.conf.ConfigurationProvider configurationProvider)

getEpoch

public long getEpoch()

Specified by:

getEpoch in interface RMContext

getNodeLabelManager

public RMNodeLabelsManager getNodeLabelManager()

Specified by:

getNodeLabelManager in interface RMContext

setNodeLabelManager

public void setNodeLabelManager(RMNodeLabelsManager mgr)

Specified by:

setNodeLabelManager in interface RMContext

getRMDelegatedNodeLabelsUpdater

public RMDelegatedNodeLabelsUpdater getRMDelegatedNodeLabelsUpdater()

Specified by:

getRMDelegatedNodeLabelsUpdater in interface RMContext

setRMDelegatedNodeLabelsUpdater

public void setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater delegatedNodeLabelsUpdater)

Specified by:

setRMDelegatedNodeLabelsUpdater in interface RMContext

setSchedulerRecoveryStartAndWaitTime

public void setSchedulerRecoveryStartAndWaitTime(long waitTime)

isSchedulerReadyForAllocatingContainers

public boolean isSchedulerReadyForAllocatingContainers()

Specified by:

isSchedulerReadyForAllocatingContainers in interface RMContext

setSystemClock

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

getSystemCredentialsForApps

public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,ByteBuffer> getSystemCredentialsForApps()

Specified by:

getSystemCredentialsForApps in interface RMContext

getActiveServiceContext

@InterfaceAudience.Private
@InterfaceStability.Unstable
public RMActiveServiceContext getActiveServiceContext()

getYarnConfiguration

public org.apache.hadoop.conf.Configuration getYarnConfiguration()

Specified by:

getYarnConfiguration in interface RMContext

setYarnConfiguration

public void setYarnConfiguration(org.apache.hadoop.conf.Configuration yarnConfiguration)

getQueuePlacementManager

public PlacementManager getQueuePlacementManager()

Specified by:

getQueuePlacementManager in interface RMContext

setQueuePlacementManager

public void setQueuePlacementManager(PlacementManager placementMgr)

Specified by:

setQueuePlacementManager in interface RMContext

getHAZookeeperConnectionState

public String getHAZookeeperConnectionState()

Specified by:

getHAZookeeperConnectionState in interface RMContext