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 | Method and Description |
---|---|
static TaskId |
TypeConverter.toYarn(TaskID id) |
Modifier and Type | Method and Description |
---|---|
static TaskID |
TypeConverter.fromYarn(TaskId id) |
Modifier and Type | Method and Description |
---|---|
TaskId |
GetTaskReportRequest.getTaskId() |
TaskId |
KillTaskRequest.getTaskId() |
Modifier and Type | Method and Description |
---|---|
void |
GetTaskReportRequest.setTaskId(TaskId taskId) |
void |
KillTaskRequest.setTaskId(TaskId taskId) |
Modifier and Type | Method and Description |
---|---|
TaskId |
KillTaskRequestPBImpl.getTaskId() |
TaskId |
GetTaskReportRequestPBImpl.getTaskId() |
Modifier and Type | Method and Description |
---|---|
void |
KillTaskRequestPBImpl.setTaskId(TaskId taskId) |
void |
GetTaskReportRequestPBImpl.setTaskId(TaskId taskId) |
Modifier and Type | Method and Description |
---|---|
TaskId |
TaskReport.getTaskId() |
abstract TaskId |
TaskAttemptId.getTaskId() |
Modifier and Type | Method and Description |
---|---|
int |
TaskId.compareTo(TaskId other) |
void |
TaskReport.setTaskId(TaskId taskId) |
abstract void |
TaskAttemptId.setTaskId(TaskId taskId) |
Modifier and Type | Class and Description |
---|---|
class |
TaskIdPBImpl |
Modifier and Type | Method and Description |
---|---|
TaskId |
TaskReportPBImpl.getTaskId() |
TaskId |
TaskAttemptIdPBImpl.getTaskId() |
Modifier and Type | Method and Description |
---|---|
void |
TaskReportPBImpl.setTaskId(TaskId taskId) |
void |
TaskAttemptIdPBImpl.setTaskId(TaskId taskId) |
Modifier and Type | Method and Description |
---|---|
Map<TaskId,JobHistoryParser.TaskInfo> |
MRAppMaster.getCompletedTaskFromPreviousRun() |
Modifier and Type | Method and Description |
---|---|
TaskId |
Task.getID() |
Modifier and Type | Method and Description |
---|---|
Map<TaskId,Task> |
Job.getTasks() |
Map<TaskId,Task> |
Job.getTasks(TaskType taskType) |
Modifier and Type | Method and Description |
---|---|
Task |
Job.getTask(TaskId taskID) |
Modifier and Type | Method and Description |
---|---|
TaskId |
JobTaskEvent.getTaskID() |
TaskId |
TaskEvent.getTaskID() |
TaskId |
JobMapTaskRescheduledEvent.getTaskID() |
Constructor and Description |
---|
JobMapTaskRescheduledEvent(TaskId taskID) |
JobTaskEvent(TaskId taskID,
TaskState taskState) |
TaskEvent(TaskId taskID,
TaskEventType type) |
TaskRecoverEvent(TaskId taskID,
JobHistoryParser.TaskInfo taskInfo,
OutputCommitter committer,
boolean recoverTaskOutput) |
Modifier and Type | Method and Description |
---|---|
TaskId |
TaskImpl.getID() |
Modifier and Type | Method and Description |
---|---|
Map<TaskId,Task> |
JobImpl.getTasks() |
Map<TaskId,Task> |
JobImpl.getTasks(TaskType taskType) |
Modifier and Type | Method and Description |
---|---|
Task |
JobImpl.getTask(TaskId taskID) |
Modifier and Type | Method and Description |
---|---|
protected void |
JobImpl.scheduleTasks(Set<TaskId> taskIDs,
boolean recoverTaskOutput) |
Constructor and Description |
---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
TaskId |
SpeculatorEvent.getTaskID() |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultSpeculator.addSpeculativeAttempt(TaskId taskID) |
long |
NullTaskRuntimesEngine.estimatedNewAttemptRuntime(TaskId id) |
long |
TaskRuntimeEstimator.estimatedNewAttemptRuntime(TaskId id)
Estimates how long a new attempt on this task will take if we start
one now
|
long |
NullTaskRuntimesEngine.thresholdRuntime(TaskId id) |
long |
TaskRuntimeEstimator.thresholdRuntime(TaskId id)
Find a maximum reasonable execution wallclock time.
|
Constructor and Description |
---|
SpeculatorEvent(TaskId taskID,
int containersNeededChange) |
Modifier and Type | Method and Description |
---|---|
TaskId |
CompletedTask.getID() |
Modifier and Type | Method and Description |
---|---|
Map<TaskId,Task> |
CompletedJob.getTasks() |
Map<TaskId,Task> |
PartialJob.getTasks() |
Map<TaskId,Task> |
CompletedJob.getTasks(TaskType taskType) |
Map<TaskId,Task> |
PartialJob.getTasks(TaskType taskType) |
Modifier and Type | Method and Description |
---|---|
Task |
CompletedJob.getTask(TaskId taskId) |
Task |
PartialJob.getTask(TaskId taskID) |
Modifier and Type | Method and Description |
---|---|
static TaskId |
MRBuilderUtils.newTaskId(JobId jobId,
int id,
TaskType taskType) |
static TaskId |
MRApps.toTaskID(String tid) |
Modifier and Type | Method and Description |
---|---|
static TaskAttemptId |
MRBuilderUtils.newTaskAttemptId(TaskId taskId,
int attemptId) |
static String |
MRApps.toString(TaskId tid) |
Copyright © 2013 Apache Software Foundation. All rights reserved.