public class TaskMessages extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TaskMessages.CancelTask
Cancels the task associated with
attemptID . |
static class |
TaskMessages.CancelTask$ |
static class |
TaskMessages.FailIntermediateResultPartitions
Fails (and releases) all intermediate result partitions identified by
executionID from the task manager. |
static class |
TaskMessages.FailIntermediateResultPartitions$ |
static class |
TaskMessages.FailTask
Triggers a fail of specified task from the outside (as opposed to the task throwing
an exception itself) with the given exception as the cause.
|
static class |
TaskMessages.FailTask$ |
static class |
TaskMessages.StopTask
Stops the task associated with
attemptID . |
static class |
TaskMessages.StopTask$ |
static class |
TaskMessages.SubmitTask
Submits a task to the task manager.
|
static class |
TaskMessages.SubmitTask$ |
static class |
TaskMessages.TaskInFinalState
Notifies the TaskManager that the task has reached its final state,
either FINISHED, CANCELED, or FAILED.
|
static class |
TaskMessages.TaskInFinalState$ |
static interface |
TaskMessages.TaskMessage
Marker trait for task messages.
|
static class |
TaskMessages.UpdatePartitionInfo
Base class for messages that update the information about location of input partitions
|
static class |
TaskMessages.UpdateTaskExecutionState
Denotes a state change of a task at the JobManager.
|
static class |
TaskMessages.UpdateTaskExecutionState$ |
static class |
TaskMessages.UpdateTaskMultiplePartitionInfos
param: executionID The task's execution attempt ID.
|
static class |
TaskMessages.UpdateTaskMultiplePartitionInfos$ |
static class |
TaskMessages.UpdateTaskSinglePartitionInfo
param: executionID The task's execution attempt ID.
|
static class |
TaskMessages.UpdateTaskSinglePartitionInfo$ |
Constructor and Description |
---|
TaskMessages() |
Modifier and Type | Method and Description |
---|---|
static TaskMessages.UpdateTaskMultiplePartitionInfos |
createUpdateTaskMultiplePartitionInfos(ExecutionAttemptID executionID,
List<IntermediateDataSetID> resultIDs,
List<InputChannelDeploymentDescriptor> partitionInfos) |
public static TaskMessages.UpdateTaskMultiplePartitionInfos createUpdateTaskMultiplePartitionInfos(ExecutionAttemptID executionID, List<IntermediateDataSetID> resultIDs, List<InputChannelDeploymentDescriptor> partitionInfos)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.