Package | Description |
---|---|
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
Modifier and Type | Class and Description |
---|---|
static class |
TaskMessages.CancelTask
Cancels the task associated with
attemptID . |
static class |
TaskMessages.FailIntermediateResultPartitions
Fails (and releases) all intermediate result partitions identified by
executionID from the task manager. |
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.StopTask
Stops the task associated with
attemptID . |
static class |
TaskMessages.SubmitTask
Submits a task to the task manager.
|
static class |
TaskMessages.TaskInFinalState
Notifies the TaskManager that the task has reached its final state,
either FINISHED, CANCELED, or FAILED.
|
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.UpdateTaskMultiplePartitionInfos
param: executionID The task's execution attempt ID.
|
static class |
TaskMessages.UpdateTaskSinglePartitionInfo
param: executionID The task's execution attempt ID.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.