Modifier and Type | Method and Description |
---|---|
protected Dispatcher |
MRAppMaster.createDispatcher() |
Dispatcher |
MRAppMaster.getDispatcher() |
Modifier and Type | Class and Description |
---|---|
class |
AsyncDispatcher
Dispatches
Event s in a separate thread. |
Modifier and Type | Method and Description |
---|---|
protected NodeStatusUpdater |
NodeManager.createNodeStatusUpdater(Context context,
Dispatcher dispatcher,
NodeHealthCheckerService healthChecker) |
Constructor and Description |
---|
NodeStatusUpdaterImpl(Context context,
Dispatcher dispatcher,
NodeHealthCheckerService healthChecker,
NodeManagerMetrics metrics) |
Constructor and Description |
---|
ContainerLocalizationImpl(Dispatcher dispatcher,
Application app,
LocalizationProtocol localization) |
Constructor and Description |
---|
ApplicationImpl(Dispatcher dispatcher,
ApplicationACLsManager aclsManager,
String user,
ApplicationId appId,
Credentials credentials,
Context context) |
Constructor and Description |
---|
ContainerImpl(Configuration conf,
Dispatcher dispatcher,
ContainerLaunchContext launchContext,
Credentials creds,
NodeManagerMetrics metrics,
ContainerTokenIdentifier containerTokenIdentifier) |
Constructor and Description |
---|
ContainerLaunch(Context context,
Configuration configuration,
Dispatcher dispatcher,
ContainerExecutor exec,
Application app,
Container container,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
ContainersLauncher(Context context,
Dispatcher dispatcher,
ContainerExecutor exec,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
Modifier and Type | Field and Description |
---|---|
protected Dispatcher |
ResourceLocalizationService.dispatcher |
Constructor and Description |
---|
LocalizedResource(LocalResourceRequest rsrc,
Dispatcher dispatcher) |
ResourceLocalizationService(Dispatcher dispatcher,
ContainerExecutor exec,
DeletionService delService,
LocalDirsHandlerService dirsHandler) |
Constructor and Description |
---|
AppLogAggregatorImpl(Dispatcher dispatcher,
DeletionService deletionService,
Configuration conf,
ApplicationId appId,
UserGroupInformation userUgi,
LocalDirsHandlerService dirsHandler,
Path remoteNodeLogFileForApp,
ContainerLogsRetentionPolicy retentionPolicy,
Map<ApplicationAccessType,String> appAcls) |
LogAggregationService(Dispatcher dispatcher,
Context context,
DeletionService deletionService,
LocalDirsHandlerService dirsHandler) |
Constructor and Description |
---|
NonAggregatingLogHandler(Dispatcher dispatcher,
DeletionService delService,
LocalDirsHandlerService dirsHandler) |
Modifier and Type | Method and Description |
---|---|
protected Dispatcher |
ResourceManager.createDispatcher() |
Dispatcher |
RMContextImpl.getDispatcher() |
Dispatcher |
RMContext.getDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
RMStateStore.setRMDispatcher(Dispatcher dispatcher)
Dispatcher used to send state operation completion events to
ResourceManager services
|
Constructor and Description |
---|
AMLivelinessMonitor(Dispatcher d) |
Constructor and Description |
---|
ContainerAllocationExpirer(Dispatcher d) |
Copyright © 2013 Apache Software Foundation. All rights reserved.