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(Dispatcher rmDispatcher, ContainerAllocationExpirer containerAllocationExpirer, AMLivelinessMonitor amLivelinessMonitor, AMLivelinessMonitor amFinishingMonitor, DelegationTokenRenewer delegationTokenRenewer, AMRMTokenSecretManager appTokenSecretManager, RMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInRM nmTokenSecretManager, ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager)
RMContextImpl(Dispatcher rmDispatcher, RMStateStore store, ContainerAllocationExpirer containerAllocationExpirer, AMLivelinessMonitor amLivelinessMonitor, AMLivelinessMonitor amFinishingMonitor, DelegationTokenRenewer delegationTokenRenewer, AMRMTokenSecretManager amRMTokenSecretManager, RMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInRM nmTokenSecretManager, ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager)

Method Summary

Methods

Modifier and Type	Method and Description
AMLivelinessMonitor	getAMFinishingMonitor()
AMLivelinessMonitor	getAMLivelinessMonitor()
AMRMTokenSecretManager	getAMRMTokenSecretManager()
ClientRMService	getClientRMService()
ClientToAMTokenSecretManagerInRM	getClientToAMTokenSecretManager()
ContainerAllocationExpirer	getContainerAllocationExpirer()
RMContainerTokenSecretManager	getContainerTokenSecretManager()
DelegationTokenRenewer	getDelegationTokenRenewer()
Dispatcher	getDispatcher()
ConcurrentMap<String,RMNode>	getInactiveRMNodes()
NMTokenSecretManagerInRM	getNMTokenSecretManager()
ConcurrentMap<ApplicationId,RMApp>	getRMApps()
RMDelegationTokenSecretManager	getRMDelegationTokenSecretManager()
ConcurrentMap<NodeId,RMNode>	getRMNodes()
RMStateStore	getStateStore()
void	setClientRMService(ClientRMService clientRMService)
void	setRMDelegationTokenSecretManager(RMDelegationTokenSecretManager delegationTokenSecretManager)
void	setStateStore(RMStateStore store)

Methods inherited from class java.lang.Object

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

Constructor Detail

RMContextImpl

public RMContextImpl(Dispatcher rmDispatcher,
             RMStateStore store,
             ContainerAllocationExpirer containerAllocationExpirer,
             AMLivelinessMonitor amLivelinessMonitor,
             AMLivelinessMonitor amFinishingMonitor,
             DelegationTokenRenewer delegationTokenRenewer,
             AMRMTokenSecretManager amRMTokenSecretManager,
             RMContainerTokenSecretManager containerTokenSecretManager,
             NMTokenSecretManagerInRM nmTokenSecretManager,
             ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager)

RMContextImpl

public RMContextImpl(Dispatcher rmDispatcher,
             ContainerAllocationExpirer containerAllocationExpirer,
             AMLivelinessMonitor amLivelinessMonitor,
             AMLivelinessMonitor amFinishingMonitor,
             DelegationTokenRenewer delegationTokenRenewer,
             AMRMTokenSecretManager appTokenSecretManager,
             RMContainerTokenSecretManager containerTokenSecretManager,
             NMTokenSecretManagerInRM nmTokenSecretManager,
             ClientToAMTokenSecretManagerInRM clientToAMTokenSecretManager)

Method Detail

getDispatcher

public Dispatcher getDispatcher()

Specified by:

getDispatcher in interface RMContext

getStateStore

public RMStateStore getStateStore()

Specified by:

getStateStore in interface RMContext

getRMApps

public ConcurrentMap<ApplicationId,RMApp> getRMApps()

Specified by:

getRMApps in interface RMContext

getRMNodes

public ConcurrentMap<NodeId,RMNode> getRMNodes()

Specified by:

getRMNodes in interface RMContext

getInactiveRMNodes

public ConcurrentMap<String,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

getClientToAMTokenSecretManager

public ClientToAMTokenSecretManagerInRM getClientToAMTokenSecretManager()

Specified by:

getClientToAMTokenSecretManager in interface RMContext

setStateStore

public void setStateStore(RMStateStore store)

getClientRMService

public ClientRMService getClientRMService()

Specified by:

getClientRMService 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