Package | Description |
---|---|
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.executiongraph | |
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. |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
static ExecutionState |
ExecutionState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ExecutionState[] |
ExecutionState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static ExecutionState |
ExecutionJobVertex.getAggregateJobVertexState(int[] verticesPerState,
int parallelism) |
ExecutionState |
ExecutionJobVertex.getAggregateState() |
ExecutionState |
ExecutionVertex.getExecutionState() |
ExecutionState |
Execution.getState() |
Modifier and Type | Method and Description |
---|---|
long |
ExecutionVertex.getStateTimestamp(ExecutionState state) |
long |
Execution.getStateTimestamp(ExecutionState state) |
Modifier and Type | Method and Description |
---|---|
ExecutionState |
ExecutionGraphMessages.ExecutionStateChanged.newExecutionState() |
Modifier and Type | Method and Description |
---|---|
scala.util.Either<scala.Tuple3<IntermediateDataSetID,ResultPartitionID,ExecutionState>,Exception> |
TaskMessages.PartitionProducerState.result() |
Constructor and Description |
---|
ExecutionStateChanged(JobID jobID,
JobVertexID vertexID,
String taskName,
int totalNumberOfSubTasks,
int subtaskIndex,
ExecutionAttemptID executionID,
ExecutionState newExecutionState,
long timestamp,
String optionalMessage) |
Constructor and Description |
---|
PartitionProducerState(ExecutionAttemptID receiverExecutionId,
scala.util.Either<scala.Tuple3<IntermediateDataSetID,ResultPartitionID,ExecutionState>,Exception> result) |
Modifier and Type | Method and Description |
---|---|
ExecutionState |
TaskExecutionState.getExecutionState()
Returns the new execution state of the task.
|
ExecutionState |
Task.getExecutionState()
Returns the current execution state of the task.
|
Modifier and Type | Method and Description |
---|---|
void |
Task.onPartitionStateUpdate(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ExecutionState partitionState)
Answer to a partition state check issued after a failed partition request.
|
Constructor and Description |
---|
TaskExecutionState(JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState)
Creates a new task execution state update, with no attached exception and no accumulators.
|
TaskExecutionState(JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error)
Creates a new task execution state update, with an attached exception but no accumulators.
|
TaskExecutionState(JobID jobID,
ExecutionAttemptID executionId,
ExecutionState executionState,
Throwable error,
AccumulatorSnapshot accumulators)
Creates a new task execution state update, with an attached exception.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.