Modifier and Type | Method and Description |
---|---|
void |
TaskAttemptListenerImpl.registerLaunchedTask(TaskAttemptId attemptID,
WrappedJvmID jvmId) |
void |
TaskAttemptListenerImpl.unregister(TaskAttemptId attemptID,
WrappedJvmID jvmID) |
Modifier and Type | Method and Description |
---|---|
static TaskAttemptId |
TypeConverter.toYarn(TaskAttemptID id) |
static TaskAttemptId |
TypeConverter.toYarn(TaskAttemptID id) |
Modifier and Type | Method and Description |
---|---|
static TaskAttemptID |
TypeConverter.fromYarn(TaskAttemptId id) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
GetDiagnosticsRequest.getTaskAttemptId() |
TaskAttemptId |
FailTaskAttemptRequest.getTaskAttemptId() |
TaskAttemptId |
KillTaskAttemptRequest.getTaskAttemptId() |
TaskAttemptId |
GetTaskAttemptReportRequest.getTaskAttemptId() |
Modifier and Type | Method and Description |
---|---|
void |
GetDiagnosticsRequest.setTaskAttemptId(TaskAttemptId taskAttemptId) |
void |
FailTaskAttemptRequest.setTaskAttemptId(TaskAttemptId taskAttemptId) |
void |
KillTaskAttemptRequest.setTaskAttemptId(TaskAttemptId taskAttemptId) |
void |
GetTaskAttemptReportRequest.setTaskAttemptId(TaskAttemptId taskAttemptId) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
GetTaskAttemptReportRequestPBImpl.getTaskAttemptId() |
TaskAttemptId |
FailTaskAttemptRequestPBImpl.getTaskAttemptId() |
TaskAttemptId |
KillTaskAttemptRequestPBImpl.getTaskAttemptId() |
TaskAttemptId |
GetDiagnosticsRequestPBImpl.getTaskAttemptId() |
Modifier and Type | Method and Description |
---|---|
void |
GetTaskAttemptReportRequestPBImpl.setTaskAttemptId(TaskAttemptId taskAttemptId) |
void |
FailTaskAttemptRequestPBImpl.setTaskAttemptId(TaskAttemptId taskAttemptId) |
void |
KillTaskAttemptRequestPBImpl.setTaskAttemptId(TaskAttemptId taskAttemptId) |
void |
GetDiagnosticsRequestPBImpl.setTaskAttemptId(TaskAttemptId taskAttemptId) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
TaskAttemptCompletionEvent.getAttemptId() |
TaskAttemptId |
TaskReport.getRunningAttempt(int index) |
TaskAttemptId |
TaskReport.getSuccessfulAttempt() |
TaskAttemptId |
TaskAttemptReport.getTaskAttemptId() |
Modifier and Type | Method and Description |
---|---|
List<TaskAttemptId> |
TaskReport.getRunningAttemptsList() |
Modifier and Type | Method and Description |
---|---|
void |
TaskReport.addRunningAttempt(TaskAttemptId taskAttempt) |
int |
TaskAttemptId.compareTo(TaskAttemptId other) |
void |
TaskAttemptCompletionEvent.setAttemptId(TaskAttemptId taskAttemptId) |
void |
TaskReport.setSuccessfulAttempt(TaskAttemptId taskAttempt) |
void |
TaskAttemptReport.setTaskAttemptId(TaskAttemptId taskAttemptId) |
Modifier and Type | Method and Description |
---|---|
void |
TaskReport.addAllRunningAttempts(List<TaskAttemptId> taskAttempts) |
Modifier and Type | Class and Description |
---|---|
class |
TaskAttemptIdPBImpl |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
TaskAttemptCompletionEventPBImpl.getAttemptId() |
TaskAttemptId |
TaskReportPBImpl.getRunningAttempt(int index) |
TaskAttemptId |
TaskReportPBImpl.getSuccessfulAttempt() |
TaskAttemptId |
TaskAttemptReportPBImpl.getTaskAttemptId() |
Modifier and Type | Method and Description |
---|---|
List<TaskAttemptId> |
TaskReportPBImpl.getRunningAttemptsList() |
Modifier and Type | Method and Description |
---|---|
void |
TaskReportPBImpl.addRunningAttempt(TaskAttemptId runningAttempts) |
void |
TaskAttemptCompletionEventPBImpl.setAttemptId(TaskAttemptId attemptId) |
void |
TaskReportPBImpl.setSuccessfulAttempt(TaskAttemptId successfulAttempt) |
void |
TaskAttemptReportPBImpl.setTaskAttemptId(TaskAttemptId taskAttemptId) |
Modifier and Type | Method and Description |
---|---|
void |
TaskReportPBImpl.addAllRunningAttempts(List<TaskAttemptId> runningAttempts) |
Modifier and Type | Method and Description |
---|---|
void |
TaskHeartbeatHandler.progressing(TaskAttemptId attemptID) |
void |
TaskHeartbeatHandler.register(TaskAttemptId attemptID) |
void |
TaskAttemptListener.registerLaunchedTask(TaskAttemptId attemptID,
WrappedJvmID jvmID)
Register task attempt.
|
void |
TaskHeartbeatHandler.unregister(TaskAttemptId attemptID) |
void |
TaskAttemptListener.unregister(TaskAttemptId attemptID,
WrappedJvmID jvmID)
Unregister the JVM and the attempt associated with it.
|
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
CommitterTaskAbortEvent.getAttemptID() |
Constructor and Description |
---|
CommitterTaskAbortEvent(TaskAttemptId attemptID,
TaskAttemptContext attemptContext) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
TaskAttempt.getID() |
Modifier and Type | Method and Description |
---|---|
Map<TaskAttemptId,TaskAttempt> |
Task.getAttempts() |
Modifier and Type | Method and Description |
---|---|
boolean |
Task.canCommit(TaskAttemptId taskAttemptID)
Can the output of the taskAttempt be committed.
|
TaskAttempt |
Task.getAttempt(TaskAttemptId attemptID) |
Modifier and Type | Field and Description |
---|---|
TaskAttemptId |
TaskAttemptStatusUpdateEvent.TaskAttemptStatus.id |
Modifier and Type | Field and Description |
---|---|
List<TaskAttemptId> |
TaskAttemptStatusUpdateEvent.TaskAttemptStatus.fetchFailedMaps |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
JobTaskAttemptFetchFailureEvent.getReduce() |
TaskAttemptId |
TaskTAttemptEvent.getTaskAttemptID() |
TaskAttemptId |
TaskAttemptEvent.getTaskAttemptID() |
Modifier and Type | Method and Description |
---|---|
List<TaskAttemptId> |
JobTaskAttemptFetchFailureEvent.getMaps() |
Constructor and Description |
---|
JobTaskAttemptFetchFailureEvent(TaskAttemptId reduce,
List<TaskAttemptId> maps) |
TaskAttemptContainerAssignedEvent(TaskAttemptId id,
Container container,
Map<ApplicationAccessType,String> applicationACLs) |
TaskAttemptContainerLaunchedEvent(TaskAttemptId id,
int shufflePort)
Create a new TaskAttemptEvent.
|
TaskAttemptDiagnosticsUpdateEvent(TaskAttemptId attemptID,
String diagnosticInfo) |
TaskAttemptEvent(TaskAttemptId id,
TaskAttemptEventType type)
Create a new TaskAttemptEvent.
|
TaskAttemptKillEvent(TaskAttemptId attemptID,
String message) |
TaskAttemptRecoverEvent(TaskAttemptId id,
JobHistoryParser.TaskAttemptInfo taInfo,
OutputCommitter committer,
boolean recoverOutput) |
TaskAttemptStatusUpdateEvent(TaskAttemptId id,
TaskAttemptStatusUpdateEvent.TaskAttemptStatus taskAttemptStatus) |
TaskTAttemptEvent(TaskAttemptId id,
TaskEventType type) |
Constructor and Description |
---|
JobTaskAttemptFetchFailureEvent(TaskAttemptId reduce,
List<TaskAttemptId> maps) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
TaskAttemptImpl.getID() |
Modifier and Type | Method and Description |
---|---|
Map<TaskAttemptId,TaskAttempt> |
TaskImpl.getAttempts() |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskImpl.canCommit(TaskAttemptId taskAttemptID) |
TaskAttempt |
TaskImpl.getAttempt(TaskAttemptId attemptID) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
ContainerLauncherEvent.getTaskAttemptID() |
Constructor and Description |
---|
ContainerLauncherEvent(TaskAttemptId taskAttemptID,
ContainerId containerID,
String containerMgrAddress,
Token containerToken,
ContainerLauncher.EventType type) |
ContainerRemoteLaunchEvent(TaskAttemptId taskAttemptID,
ContainerLaunchContext containerLaunchContext,
Container allocatedContainer,
Task remoteTask) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
ContainerAllocatorEvent.getAttemptID() |
Modifier and Type | Method and Description |
---|---|
TaskAttemptEvent |
RMContainerAllocator.createContainerFinishedEvent(ContainerStatus cont,
TaskAttemptId attemptID) |
static ContainerRequestEvent |
ContainerRequestEvent.createContainerRequestEventForFailedContainer(TaskAttemptId attemptID,
Resource capability) |
Constructor and Description |
---|
ContainerAllocatorEvent(TaskAttemptId attemptID,
ContainerAllocator.EventType type) |
ContainerFailedEvent(TaskAttemptId attemptID,
String contMgrAddr) |
ContainerRequestEvent(TaskAttemptId attemptID,
Resource capability,
String[] hosts,
String[] racks) |
Modifier and Type | Method and Description |
---|---|
long |
NullTaskRuntimesEngine.attemptEnrolledTime(TaskAttemptId attemptID) |
long |
TaskRuntimeEstimator.attemptEnrolledTime(TaskAttemptId attemptID) |
long |
LegacyTaskRuntimeEstimator.estimatedRuntime(TaskAttemptId attemptID) |
long |
ExponentiallySmoothedTaskRuntimeEstimator.estimatedRuntime(TaskAttemptId id) |
long |
NullTaskRuntimesEngine.estimatedRuntime(TaskAttemptId id) |
long |
TaskRuntimeEstimator.estimatedRuntime(TaskAttemptId id)
Estimate a task attempt's total runtime.
|
long |
LegacyTaskRuntimeEstimator.runtimeEstimateVariance(TaskAttemptId attemptID) |
long |
ExponentiallySmoothedTaskRuntimeEstimator.runtimeEstimateVariance(TaskAttemptId id) |
long |
NullTaskRuntimesEngine.runtimeEstimateVariance(TaskAttemptId id) |
long |
TaskRuntimeEstimator.runtimeEstimateVariance(TaskAttemptId id)
Computes the width of the error band of our estimate of the task
runtime as returned by
TaskRuntimeEstimator.estimatedRuntime(TaskAttemptId) |
Constructor and Description |
---|
SpeculatorEvent(TaskAttemptId attemptID,
boolean flag,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
TaskAttemptId |
CompletedTaskAttempt.getID() |
Modifier and Type | Method and Description |
---|---|
Map<TaskAttemptId,TaskAttempt> |
CompletedTask.getAttempts() |
Modifier and Type | Method and Description |
---|---|
boolean |
CompletedTask.canCommit(TaskAttemptId taskAttemptID) |
TaskAttempt |
CompletedTask.getAttempt(TaskAttemptId attemptID) |
Modifier and Type | Method and Description |
---|---|
static TaskAttemptId |
MRBuilderUtils.newTaskAttemptId(TaskId taskId,
int attemptId) |
static TaskAttemptId |
MRApps.toTaskAttemptID(String taid) |
Modifier and Type | Method and Description |
---|---|
static String |
MRApps.toString(TaskAttemptId taid) |
Copyright © 2013 Apache Software Foundation. All rights reserved.