Package org.apache.hadoop.yarn.server.resourcemanager

Class RMActiveServiceContext

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.RMActiveServiceContext
@Private @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 Details

  • Method Details

    • setStateStore

      @Private @Unstable public void setStateStore(RMStateStore store)

    • getClientRMService

      @Private @Unstable public ClientRMService getClientRMService()

    • getApplicationMasterService

      @Private @Unstable public ApplicationMasterService getApplicationMasterService()

    • getResourceTrackerService

      @Private @Unstable public ResourceTrackerService getResourceTrackerService()

    • getStateStore

      @Private @Unstable public RMStateStore getStateStore()

    • getRMApps

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

    • getRMNodes

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

    • getInactiveRMNodes

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

    • getContainerAllocationExpirer

      @Private @Unstable public ContainerAllocationExpirer getContainerAllocationExpirer()

    • getAMLivelinessMonitor

      @Private @Unstable public AMLivelinessMonitor getAMLivelinessMonitor()

    • getAMFinishingMonitor

      @Private @Unstable public AMLivelinessMonitor getAMFinishingMonitor()

    • getDelegationTokenRenewer

      @Private @Unstable public DelegationTokenRenewer getDelegationTokenRenewer()

    • getAMRMTokenSecretManager

      @Private @Unstable public AMRMTokenSecretManager getAMRMTokenSecretManager()

    • getContainerTokenSecretManager

      @Private @Unstable public RMContainerTokenSecretManager getContainerTokenSecretManager()

    • getNMTokenSecretManager

      @Private @Unstable public NMTokenSecretManagerInRM getNMTokenSecretManager()

    • getScheduler

      @Private @Unstable public ResourceScheduler getScheduler()

    • getReservationSystem

      @Private @Unstable public ReservationSystem getReservationSystem()

    • getNodesListManager

      @Private @Unstable public NodesListManager getNodesListManager()

    • getClientToAMTokenSecretManager

      @Private @Unstable public ClientToAMTokenSecretManagerInRM getClientToAMTokenSecretManager()

    • setClientRMService

      @Private @Unstable public void setClientRMService(ClientRMService clientRMService)

    • getRMDelegationTokenSecretManager

      @Private @Unstable public RMDelegationTokenSecretManager getRMDelegationTokenSecretManager()

    • setRMDelegationTokenSecretManager

      @Private @Unstable public void setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)

    • setWorkPreservingRecoveryEnabled

      @Private @Unstable public void setWorkPreservingRecoveryEnabled(boolean enabled)

    • isWorkPreservingRecoveryEnabled

      @Private @Unstable public boolean isWorkPreservingRecoveryEnabled()

    • getEpoch

      @Private @Unstable public long getEpoch()

    • getNodeLabelManager

      @Private @Unstable public RMNodeLabelsManager getNodeLabelManager()

    • setNodeLabelManager

      @Private @Unstable public void setNodeLabelManager(RMNodeLabelsManager mgr)

    • getNodeAttributesManager

      @Private @Unstable public org.apache.hadoop.yarn.nodelabels.NodeAttributesManager getNodeAttributesManager()

    • setNodeAttributesManager

      @Private @Unstable public void setNodeAttributesManager(org.apache.hadoop.yarn.nodelabels.NodeAttributesManager mgr)

    • getAllocationTagsManager

      @Private @Unstable public AllocationTagsManager getAllocationTagsManager()

    • setAllocationTagsManager

      @Private @Unstable public void setAllocationTagsManager(AllocationTagsManager allocationTagsManager)

    • getPlacementConstraintManager

      @Private @Unstable public PlacementConstraintManager getPlacementConstraintManager()

    • setPlacementConstraintManager

      @Private @Unstable public void setPlacementConstraintManager(PlacementConstraintManager placementConstraintManager)

    • getRMDelegatedNodeLabelsUpdater

      @Private @Unstable public RMDelegatedNodeLabelsUpdater getRMDelegatedNodeLabelsUpdater()

    • setRMDelegatedNodeLabelsUpdater

      @Private @Unstable public void setRMDelegatedNodeLabelsUpdater(RMDelegatedNodeLabelsUpdater nodeLablesUpdater)

    • getMultiNodeSortingManager

      @Private @Unstable public MultiNodeSortingManager<SchedulerNode> getMultiNodeSortingManager()

    • setMultiNodeSortingManager

      @Private @Unstable public void setMultiNodeSortingManager(MultiNodeSortingManager<SchedulerNode> multiNodeSortingManager)

    • setSchedulerRecoveryStartAndWaitTime

      @Private @Unstable public void setSchedulerRecoveryStartAndWaitTime(long waitTime)

    • isSchedulerReadyForAllocatingContainers

      @Private @Unstable public boolean isSchedulerReadyForAllocatingContainers()

    • setSystemClock

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

    • getSystemCredentialsForApps

      @Private @Unstable public ConcurrentMap<org.apache.hadoop.yarn.api.records.ApplicationId,org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.SystemCredentialsForAppsProto> getSystemCredentialsForApps()

    • getQueuePlacementManager

      @Private @Unstable public PlacementManager getQueuePlacementManager()

    • setQueuePlacementManager

      @Private @Unstable public void setQueuePlacementManager(PlacementManager placementMgr)

    • setRMAppLifetimeMonitor

      @Private @Unstable public void setRMAppLifetimeMonitor(RMAppLifetimeMonitor lifetimeMonitor)

    • getRMAppLifetimeMonitor

      @Private @Unstable public RMAppLifetimeMonitor getRMAppLifetimeMonitor()

    • getNodeManagerQueueLimitCalculator

      @Private @Unstable public QueueLimitCalculator getNodeManagerQueueLimitCalculator()

    • setContainerQueueLimitCalculator

      @Private @Unstable public void setContainerQueueLimitCalculator(QueueLimitCalculator limitCalculator)

    • getResourceProfilesManager

      public ResourceProfilesManager getResourceProfilesManager()

    • setResourceProfilesManager

      public void setResourceProfilesManager(ResourceProfilesManager resourceProfilesManager)

    • getProxyCAManager

      @Private @Unstable public ProxyCAManager getProxyCAManager()

    • setProxyCAManager

      @Private @Unstable public void setProxyCAManager(ProxyCAManager proxyCAManager)

    • getVolumeManager

      @Private @Unstable public VolumeManager getVolumeManager()

    • setVolumeManager

      @Private @Unstable public void setVolumeManager(VolumeManager volumeManager)

    • getTokenSequenceNo

      public Long getTokenSequenceNo()
      Get token sequence no.
      Returns:
      the tokenSequenceNo

    • incrTokenSequenceNo

      public void incrTokenSequenceNo()
      Increment token sequence no.