Constructor and Description |
---|
LocalContainerLauncher(AppContext context,
TaskUmbilicalProtocol umbilical) |
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) |
TaskAttemptListenerImpl(AppContext context,
JobTokenSecretManager jobTokenSecretManager,
RMHeartbeatHandler rmHeartbeatHandler) |
Constructor and Description |
---|
JobHistoryEventHandler(AppContext context,
int startCount) |
Modifier and Type | Class and Description |
---|---|
class |
MRAppMaster.RunningAppContext |
Modifier and Type | Method and Description |
---|---|
AppContext |
MRAppMaster.getContext() |
Modifier and Type | Method and Description |
---|---|
protected ClientService |
MRAppMaster.createClientService(AppContext context) |
protected EventHandler<CommitterEvent> |
MRAppMaster.createCommitterEventHandler(AppContext context,
OutputCommitter committer) |
protected ContainerAllocator |
MRAppMaster.createContainerAllocator(ClientService clientService,
AppContext context) |
protected ContainerLauncher |
MRAppMaster.createContainerLauncher(AppContext context) |
protected EventHandler<JobHistoryEvent> |
MRAppMaster.createJobHistoryHandler(AppContext context) |
protected Speculator |
MRAppMaster.createSpeculator(Configuration conf,
AppContext context) |
protected TaskAttemptListener |
MRAppMaster.createTaskAttemptListener(AppContext context) |
Constructor and Description |
---|
MRClientService(AppContext appContext) |
Constructor and Description |
---|
CommitterEventHandler(AppContext context,
OutputCommitter committer,
RMHeartbeatHandler rmHeartbeatHandler) |
Modifier and Type | Field and Description |
---|---|
protected AppContext |
TaskImpl.appContext |
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) |
Constructor and Description |
---|
ContainerLauncherImpl(AppContext context) |
Constructor and Description |
---|
LocalContainerAllocator(ClientService clientService,
AppContext context,
String nmHost,
int nmPort,
int nmHttpPort,
ContainerId cId) |
Modifier and Type | Method and Description |
---|---|
protected AppContext |
RMCommunicator.getContext() |
Constructor and Description |
---|
RMCommunicator(ClientService clientService,
AppContext context) |
RMContainerAllocator(ClientService clientService,
AppContext context) |
RMContainerRequestor(ClientService clientService,
AppContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ExponentiallySmoothedTaskRuntimeEstimator.contextualize(Configuration conf,
AppContext context) |
void |
NullTaskRuntimesEngine.contextualize(Configuration conf,
AppContext context) |
void |
TaskRuntimeEstimator.contextualize(Configuration conf,
AppContext context) |
Constructor and Description |
---|
DefaultSpeculator(Configuration conf,
AppContext context) |
DefaultSpeculator(Configuration conf,
AppContext context,
Clock clock) |
DefaultSpeculator(Configuration conf,
AppContext context,
TaskRuntimeEstimator estimator,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
static Job |
AMWebServices.getJobFromJobIdString(String jid,
AppContext appCtx)
convert a job id string to an actual job and handle all the error checking.
|
Constructor and Description |
---|
AMWebServices(App app,
AppContext context) |
Constructor and Description |
---|
AppInfo(App app,
AppContext context) |
BlacklistedNodesInfo(AppContext appContext) |
JobCounterInfo(AppContext ctx,
Job job) |
Modifier and Type | Interface and Description |
---|---|
interface |
HistoryContext |
Modifier and Type | Class and Description |
---|---|
class |
JobHistory
Loads and manages the Job history cache.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.