Modifier and Type | Class and Description |
---|---|
class |
LocalContainerLauncher
Runs the container task locally in a thread.
|
class |
ResourceMgrDelegate |
class |
ShuffleHandler |
class |
TaskAttemptListenerImpl
This class is responsible for talking to the task umblical.
|
Modifier and Type | Class and Description |
---|---|
class |
JobHistoryCopyService
Reads in history events from the JobHistoryFile and sends them out again
to be recorded.
|
class |
JobHistoryEventHandler
The job history events get routed to this class.
|
Modifier and Type | Class and Description |
---|---|
class |
MRAppMaster
The Map-Reduce Application Master.
|
class |
TaskHeartbeatHandler
This class keeps track of tasks that have already been launched.
|
Modifier and Type | Method and Description |
---|---|
protected AbstractService |
MRAppMaster.createStagingDirCleaningService() |
Modifier and Type | Class and Description |
---|---|
class |
MRClientService
This module is responsible for talking to the
jobclient (user facing).
|
Modifier and Type | Class and Description |
---|---|
class |
CommitterEventHandler |
Modifier and Type | Class and Description |
---|---|
class |
ContainerLauncherImpl
This class is responsible for launching of containers.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalContainerAllocator
Allocates containers locally.
|
Modifier and Type | Class and Description |
---|---|
class |
RMCommunicator
Registers/unregisters to RM and sends heartbeats to RM.
|
class |
RMContainerAllocator
Allocates the container from the ResourceManager scheduler.
|
class |
RMContainerRequestor
Keeps the data structures to send container requests to RM.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultSpeculator |
Modifier and Type | Class and Description |
---|---|
class |
CachedHistoryStorage
Manages an in memory cache of parsed Job History files.
|
class |
HistoryClientService
This module is responsible for talking to the
JobClient (user facing).
|
class |
HistoryFileManager
This class provides a way to interact with history files in a thread safe
manor.
|
class |
JobHistory
Loads and manages the Job history cache.
|
class |
JobHistoryServer
JobHistoryServer is responsible for servicing all job history
related requests from client. |
Modifier and Type | Class and Description |
---|---|
class |
CompositeService
Composition of services.
|
Modifier and Type | Class and Description |
---|---|
class |
AMRMClient<T extends AMRMClient.ContainerRequest> |
class |
NMClient |
class |
YarnClient |
Modifier and Type | Class and Description |
---|---|
class |
AMRMClientAsync<T extends AMRMClient.ContainerRequest>
AMRMClientAsync handles communication with the ResourceManager
and provides asynchronous updates on events such as container allocations and
completions. |
class |
NMClientAsync
NMClientAsync handles communication with all the NodeManagers
and provides asynchronous updates on getting responses from them. |
Modifier and Type | Class and Description |
---|---|
class |
AMRMClientAsyncImpl<T extends AMRMClient.ContainerRequest> |
class |
NMClientAsyncImpl |
Modifier and Type | Class and Description |
---|---|
class |
AMRMClientImpl<T extends AMRMClient.ContainerRequest> |
class |
NMClientImpl
This class implements
NMClient . |
class |
YarnClientImpl |
Modifier and Type | Class and Description |
---|---|
class |
AsyncDispatcher
Dispatches
Event s in a separate thread. |
Modifier and Type | Class and Description |
---|---|
class |
AggregatedLogDeletionService
A service that periodically deletes aggregated logs.
|
Modifier and Type | Class and Description |
---|---|
class |
AuxiliaryService
A generic service that will be started by the NodeManager.
|
Modifier and Type | Class and Description |
---|---|
class |
DeletionService |
class |
LocalDirsHandlerService
The class which provides functionality of checking the health of the local
directories of a node.
|
class |
NodeHealthCheckerService
The class which provides functionality of checking the health of the node and
reporting back to the service for which the health checker has been asked to
report.
|
class |
NodeHealthScriptRunner
The class which provides functionality of checking the health of the node
using the configured node health script and reporting back to the service
for which the health checker has been asked to report.
|
class |
NodeManager |
class |
NodeResourceMonitorImpl |
class |
NodeStatusUpdaterImpl |
Modifier and Type | Class and Description |
---|---|
class |
AuxServices |
class |
ContainerManagerImpl |
Modifier and Type | Class and Description |
---|---|
class |
ContainersLauncher
The launcher for the containers.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceLocalizationService |
Modifier and Type | Class and Description |
---|---|
class |
LogAggregationService |
Modifier and Type | Class and Description |
---|---|
class |
NonAggregatingLogHandler
Log Handler which schedules deletion of log files based on the configured log
retention time.
|
Modifier and Type | Class and Description |
---|---|
class |
ContainersMonitorImpl |
Modifier and Type | Class and Description |
---|---|
class |
WebServer |
Modifier and Type | Class and Description |
---|---|
class |
AdminService |
class |
ApplicationMasterService |
class |
ClientRMService
The client interface to the Resource Manager.
|
class |
NMLivelinessMonitor |
class |
NodesListManager |
class |
ResourceManager
The ResourceManager is the main class that is a set of components.
|
static class |
ResourceManager.SchedulerEventDispatcher |
class |
ResourceTrackerService |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationMasterLauncher |
Modifier and Type | Class and Description |
---|---|
class |
SchedulingMonitor |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemRMStateStore |
class |
MemoryRMStateStore |
class |
NullRMStateStore |
class |
RMStateStore |
Modifier and Type | Class and Description |
---|---|
class |
AMLivelinessMonitor |
Modifier and Type | Class and Description |
---|---|
class |
ContainerAllocationExpirer |
Modifier and Type | Class and Description |
---|---|
class |
DelegationTokenRenewer
Service to renew application delegation tokens.
|
Modifier and Type | Class and Description |
---|---|
class |
WebAppProxy |
class |
WebAppProxyServer
ProxyServer will sit in between the end user and AppMaster
web interfaces.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractLivelinessMonitor<O>
A simple liveliness monitor with which clients can register, trust the
component to monitor liveliness, get a call-back on expiry and then finally
unregister.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.