org.apache.hadoop.yarn.server.resourcemanager

Interface RMContext

All Superinterfaces:

org.apache.hadoop.yarn.ams.ApplicationMasterServiceContext

All Known Implementing Classes:

RMContextImpl

public interface RMContext
extends org.apache.hadoop.yarn.ams.ApplicationMasterServiceContext

Context of the ResourceManager.

Method Summary

Modifier and Type	Method and Description
AllocationTagsManager	getAllocationTagsManager()
AMLivelinessMonitor	getAMFinishingMonitor()
AMLivelinessMonitor	getAMLivelinessMonitor()
AMRMTokenSecretManager	getAMRMTokenSecretManager()
ApplicationMasterService	getApplicationMasterService()
String	getAppProxyUrl(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
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()
QueueLimitCalculator	getNodeManagerQueueLimitCalculator()
NodesListManager	getNodesListManager()
PlacementConstraintManager	getPlacementConstraintManager()
PlacementManager	getQueuePlacementManager()
ReservationSystem	getReservationSystem()
ResourceManager	getResourceManager()
ResourceProfilesManager	getResourceProfilesManager()
ResourceTrackerService	getResourceTrackerService()
AdminService	getRMAdminService()
RMApplicationHistoryWriter	getRMApplicationHistoryWriter()
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()
RMTimelineCollectorManager	getRMTimelineCollectorManager()
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	setAllocationTagsManager(AllocationTagsManager allocationTagsManager)
void	setClientRMService(ClientRMService clientRMService)
void	setLeaderElectorService(EmbeddedElector elector)
void	setNodeLabelManager(RMNodeLabelsManager mgr)
void	setPlacementConstraintManager(PlacementConstraintManager placementConstraintManager)
void	setQueuePlacementManager(PlacementManager placementMgr)
void	setResourceProfilesManager(ResourceProfilesManager mgr)
void	setRMApplicationHistoryWriter(RMApplicationHistoryWriter rmApplicationHistoryWriter)
void	setRMAppLifetimeMonitor(RMAppLifetimeMonitor rmAppLifetimeMonitor)
void	setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater nodeLabelsUpdater)
void	setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)
void	setRMTimelineCollectorManager(RMTimelineCollectorManager timelineCollectorManager)
void	setSystemMetricsPublisher(SystemMetricsPublisher systemMetricsPublisher)

Method Detail

getDispatcher

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

isHAEnabled

boolean isHAEnabled()

getHAServiceState

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

getStateStore

RMStateStore getStateStore()

getRMApps

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

getSystemCredentialsForApps

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

getInactiveRMNodes

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

getRMNodes

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

getAMLivelinessMonitor

AMLivelinessMonitor getAMLivelinessMonitor()

getAMFinishingMonitor

AMLivelinessMonitor getAMFinishingMonitor()

getContainerAllocationExpirer

ContainerAllocationExpirer getContainerAllocationExpirer()

getDelegationTokenRenewer

DelegationTokenRenewer getDelegationTokenRenewer()

getAMRMTokenSecretManager

AMRMTokenSecretManager getAMRMTokenSecretManager()

getContainerTokenSecretManager

RMContainerTokenSecretManager getContainerTokenSecretManager()

getNMTokenSecretManager

NMTokenSecretManagerInRM getNMTokenSecretManager()

getScheduler

ResourceScheduler getScheduler()

getNodesListManager

NodesListManager getNodesListManager()

getClientToAMTokenSecretManager

ClientToAMTokenSecretManagerInRM getClientToAMTokenSecretManager()

getRMAdminService

AdminService getRMAdminService()

getClientRMService

ClientRMService getClientRMService()

getApplicationMasterService

ApplicationMasterService getApplicationMasterService()

getResourceTrackerService

ResourceTrackerService getResourceTrackerService()

setClientRMService

void setClientRMService(ClientRMService clientRMService)

getRMDelegationTokenSecretManager

RMDelegationTokenSecretManager getRMDelegationTokenSecretManager()

setRMDelegationTokenSecretManager

void setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)

getRMApplicationHistoryWriter

RMApplicationHistoryWriter getRMApplicationHistoryWriter()

setRMApplicationHistoryWriter

void setRMApplicationHistoryWriter(RMApplicationHistoryWriter rmApplicationHistoryWriter)

setSystemMetricsPublisher

void setSystemMetricsPublisher(SystemMetricsPublisher systemMetricsPublisher)

getSystemMetricsPublisher

SystemMetricsPublisher getSystemMetricsPublisher()

setRMTimelineCollectorManager

void setRMTimelineCollectorManager(RMTimelineCollectorManager timelineCollectorManager)

getRMTimelineCollectorManager

RMTimelineCollectorManager getRMTimelineCollectorManager()

getConfigurationProvider

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

isWorkPreservingRecoveryEnabled

boolean isWorkPreservingRecoveryEnabled()

getNodeLabelManager

RMNodeLabelsManager getNodeLabelManager()

setNodeLabelManager

void setNodeLabelManager(RMNodeLabelsManager mgr)

getRMDelegatedNodeLabelsUpdater

RMDelegatedNodeLabelsUpdater getRMDelegatedNodeLabelsUpdater()

setRMDelegatedNodeLabelsUpdater

void setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater nodeLabelsUpdater)

getEpoch

long getEpoch()

getReservationSystem

ReservationSystem getReservationSystem()

isSchedulerReadyForAllocatingContainers

boolean isSchedulerReadyForAllocatingContainers()

getYarnConfiguration

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

getQueuePlacementManager

PlacementManager getQueuePlacementManager()

setQueuePlacementManager

void setQueuePlacementManager(PlacementManager placementMgr)

setLeaderElectorService

void setLeaderElectorService(EmbeddedElector elector)

getLeaderElectorService

EmbeddedElector getLeaderElectorService()

getNodeManagerQueueLimitCalculator

QueueLimitCalculator getNodeManagerQueueLimitCalculator()

setRMAppLifetimeMonitor

void setRMAppLifetimeMonitor(RMAppLifetimeMonitor rmAppLifetimeMonitor)

getRMAppLifetimeMonitor

RMAppLifetimeMonitor getRMAppLifetimeMonitor()

getHAZookeeperConnectionState

String getHAZookeeperConnectionState()

getResourceManager

ResourceManager getResourceManager()

getResourceProfilesManager

ResourceProfilesManager getResourceProfilesManager()

setResourceProfilesManager

void setResourceProfilesManager(ResourceProfilesManager mgr)

getAppProxyUrl

String getAppProxyUrl(org.apache.hadoop.conf.Configuration conf,
                      org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

getAllocationTagsManager

AllocationTagsManager getAllocationTagsManager()

setAllocationTagsManager

void setAllocationTagsManager(AllocationTagsManager allocationTagsManager)

getPlacementConstraintManager

PlacementConstraintManager getPlacementConstraintManager()

setPlacementConstraintManager

void setPlacementConstraintManager(PlacementConstraintManager placementConstraintManager)