Modifier and Type | Class and Description |
---|---|
class |
LocalContainerLauncher
Runs the container task locally in a thread.
|
class |
MapTaskAttemptImpl |
class |
ReduceTaskAttemptImpl |
Constructor and Description |
---|
MapTaskAttemptImpl(TaskId taskId,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
JobSplit.TaskSplitMetaInfo splitInfo,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
ReduceTaskAttemptImpl(TaskId id,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
int numMapTasks,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
Modifier and Type | Class and Description |
---|---|
class |
JobHistoryEventHandler
The job history events get routed to this class.
|
Constructor and Description |
---|
JobHistoryCopyService(ApplicationAttemptId applicationAttemptId,
EventHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected EventHandler<CommitterEvent> |
MRAppMaster.createCommitterEventHandler(AppContext context,
OutputCommitter committer) |
protected EventHandler<JobFinishEvent> |
MRAppMaster.createJobFinishEventHandler()
create an event handler that handles the job finish event.
|
protected EventHandler<JobHistoryEvent> |
MRAppMaster.createJobHistoryHandler(AppContext context) |
EventHandler |
AppContext.getEventHandler() |
EventHandler |
MRAppMaster.RunningAppContext.getEventHandler() |
Constructor and Description |
---|
TaskHeartbeatHandler(EventHandler eventHandler,
Clock clock,
int numThreads) |
Modifier and Type | Class and Description |
---|---|
class |
CommitterEventHandler |
Modifier and Type | Class and Description |
---|---|
class |
JobImpl
Implementation of Job interface.
|
class |
MapTaskImpl |
class |
ReduceTaskImpl |
class |
TaskAttemptImpl
Implementation of TaskAttempt interface.
|
class |
TaskImpl
Implementation of Task interface.
|
Modifier and Type | Field and Description |
---|---|
protected EventHandler |
TaskImpl.eventHandler |
protected EventHandler |
TaskAttemptImpl.eventHandler |
Constructor and Description |
---|
JobImpl(JobId jobId,
ApplicationAttemptId applicationAttemptId,
Configuration conf,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
JobTokenSecretManager jobTokenSecretManager,
Credentials jobCredentials,
Clock clock,
Map<TaskId,JobHistoryParser.TaskInfo> completedTasksFromPreviousRun,
MRAppMetrics metrics,
OutputCommitter committer,
boolean newApiCommitter,
String userName,
long appSubmitTime,
List<AMInfo> amInfos,
AppContext appContext,
JobStateInternal forcedState,
String forcedDiagnostic) |
MapTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
ReduceTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path jobFile,
JobConf conf,
int numMapTasks,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
TaskAttemptImpl(TaskId taskId,
int i,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
Path jobFile,
int partition,
JobConf conf,
String[] dataLocalHosts,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
TaskImpl(JobId jobId,
TaskType taskType,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Modifier and Type | Interface and Description |
---|---|
interface |
ContainerLauncher |
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 | Interface and Description |
---|---|
interface |
ContainerAllocator |
Modifier and Type | Class and Description |
---|---|
class |
RMContainerAllocator
Allocates the container from the ResourceManager scheduler.
|
Modifier and Type | Field and Description |
---|---|
protected EventHandler |
RMCommunicator.eventHandler |
Modifier and Type | Interface and Description |
---|---|
interface |
Speculator
Speculator component.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultSpeculator |
Modifier and Type | Method and Description |
---|---|
EventHandler |
JobHistory.getEventHandler() |
Modifier and Type | Class and Description |
---|---|
protected static class |
NMClientAsyncImpl.StatefulContainer |
Modifier and Type | Field and Description |
---|---|
protected Map<Class<? extends Enum>,EventHandler> |
AsyncDispatcher.eventDispatchers |
Modifier and Type | Method and Description |
---|---|
EventHandler |
Dispatcher.getEventHandler() |
EventHandler |
AsyncDispatcher.getEventHandler() |
Modifier and Type | Method and Description |
---|---|
void |
Dispatcher.register(Class<? extends Enum> eventType,
EventHandler handler) |
void |
AsyncDispatcher.register(Class<? extends Enum> eventType,
EventHandler handler) |
Modifier and Type | Class and Description |
---|---|
class |
NodeManager |
Modifier and Type | Class and Description |
---|---|
class |
AuxServices |
class |
ContainerManagerImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
Application |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationImpl
The state machine for the representation of an Application
within the NodeManager.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Container |
Modifier and Type | Class and Description |
---|---|
class |
ContainerImpl |
Modifier and Type | Class and Description |
---|---|
class |
ContainersLauncher
The launcher for the containers.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalizedResource
Datum representing a localized resource.
|
class |
ResourceLocalizationService |
Modifier and Type | Class and Description |
---|---|
class |
LogAggregationService |
Modifier and Type | Interface and Description |
---|---|
interface |
LogHandler |
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 | Interface and Description |
---|---|
interface |
ContainersMonitor |
Modifier and Type | Class and Description |
---|---|
class |
ContainersMonitorImpl |
Modifier and Type | Class and Description |
---|---|
class |
NodesListManager |
static class |
ResourceManager.ApplicationAttemptEventDispatcher |
static class |
ResourceManager.ApplicationEventDispatcher |
static class |
ResourceManager.NodeEventDispatcher |
static class |
ResourceManager.RMContainerPreemptEventDispatcher |
static class |
ResourceManager.SchedulerEventDispatcher |
class |
RMAppManager
This class manages the list of applications for the resource manager.
|
Modifier and Type | Method and Description |
---|---|
protected EventHandler<SchedulerEvent> |
ResourceManager.createSchedulerEventDispatcher() |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationMasterLauncher |
Modifier and Type | Method and Description |
---|---|
void |
SchedulingEditPolicy.init(Configuration config,
EventHandler<ContainerPreemptEvent> dispatcher,
PreemptableResourceScheduler scheduler) |
Modifier and Type | Field and Description |
---|---|
EventHandler<ContainerPreemptEvent> |
ProportionalCapacityPreemptionPolicy.dispatcher |
Modifier and Type | Method and Description |
---|---|
void |
ProportionalCapacityPreemptionPolicy.init(Configuration config,
EventHandler<ContainerPreemptEvent> disp,
PreemptableResourceScheduler sched) |
Constructor and Description |
---|
ProportionalCapacityPreemptionPolicy(Configuration config,
EventHandler<ContainerPreemptEvent> dispatcher,
CapacityScheduler scheduler) |
ProportionalCapacityPreemptionPolicy(Configuration config,
EventHandler<ContainerPreemptEvent> dispatcher,
CapacityScheduler scheduler,
Clock clock) |
Modifier and Type | Interface and Description |
---|---|
interface |
RMApp
The interface to an Application in the ResourceManager.
|
Modifier and Type | Class and Description |
---|---|
class |
RMAppImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
RMAppAttempt
Interface to an Application Attempt in the Resource Manager.
|
Modifier and Type | Class and Description |
---|---|
class |
RMAppAttemptImpl |
Modifier and Type | Interface and Description |
---|---|
interface |
RMContainer
Represents the ResourceManager's view of an application container.
|
Modifier and Type | Class and Description |
---|---|
class |
RMContainerImpl |
Constructor and Description |
---|
RMContainerImpl(Container container,
ApplicationAttemptId appAttemptId,
NodeId nodeId,
EventHandler handler,
ContainerAllocationExpirer containerAllocationExpirer) |
Modifier and Type | Class and Description |
---|---|
class |
RMNodeImpl
This class is used to keep track of all the applications/containers
running on a node.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PreemptableResourceScheduler
Interface for a scheduler that supports preemption/killing
|
interface |
ResourceScheduler
This interface is the one implemented by the schedulers.
|
interface |
YarnScheduler
This interface is used by the components to talk to the
scheduler for allocating of resources, cleaning up resources.
|
Modifier and Type | Class and Description |
---|---|
class |
CapacityScheduler |
Modifier and Type | Class and Description |
---|---|
class |
FairScheduler
A scheduler that schedules resources between a set of queues.
|
Modifier and Type | Class and Description |
---|---|
class |
FifoScheduler |
Copyright © 2013 Apache Software Foundation. All rights reserved.