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 Details

    • 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,org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.SystemCredentialsForAppsProto> 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)
    • getNodeAttributesManager

      org.apache.hadoop.yarn.nodelabels.NodeAttributesManager getNodeAttributesManager()
    • setNodeAttributesManager

      void setNodeAttributesManager(org.apache.hadoop.yarn.nodelabels.NodeAttributesManager 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)
    • getMultiNodeSortingManager

      MultiNodeSortingManager<SchedulerNode> getMultiNodeSortingManager()
    • setMultiNodeSortingManager

      void setMultiNodeSortingManager(MultiNodeSortingManager<SchedulerNode> multiNodeSortingManager)
    • getProxyCAManager

      ProxyCAManager getProxyCAManager()
    • setProxyCAManager

      void setProxyCAManager(ProxyCAManager proxyCAManager)
    • getVolumeManager

      VolumeManager getVolumeManager()
    • setVolumeManager

      void setVolumeManager(VolumeManager volumeManager)
    • getTokenSequenceNo

      long getTokenSequenceNo()
    • incrTokenSequenceNo

      void incrTokenSequenceNo()