Modifier and Type | Method and Description |
---|---|
InputChannelDeploymentDescriptor |
PartialInputChannelDeploymentDescriptor.createInputChannelDeploymentDescriptor(Execution consumerExecution)
Creates a channel deployment descriptor by completing the partition location.
|
static PartialInputChannelDeploymentDescriptor |
PartialInputChannelDeploymentDescriptor.fromEdge(IntermediateResultPartition partition,
Execution producer)
Creates a partial input channel for the given partition and producing task.
|
Modifier and Type | Field and Description |
---|---|
Execution |
ExecutionAndSlot.executionAttempt |
Modifier and Type | Method and Description |
---|---|
Execution |
ExecutionVertex.getCurrentExecutionAttempt() |
Execution |
ExecutionVertex.getPriorExecutionAttempt(int attemptNumber) |
Execution |
ExecutionVertex.resetForNewExecution(long timestamp,
long originatingGlobalModVersion)
Archives the current Execution and creates a new Execution for this vertex.
|
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
Constructor and Description |
---|
ArchivedExecution(Execution execution) |
ExecutionAndSlot(Execution executionAttempt,
Future<SimpleSlot> slotFuture) |
IllegalExecutionStateException(Execution execution,
ExecutionState expected,
ExecutionState actual)
Creates a new IllegalExecutionStateException with the error message indicating
the expected and actual state.
|
Modifier and Type | Method and Description |
---|---|
void |
FailoverRegion.onExecutionFail(Execution taskExecution,
Throwable cause) |
void |
RestartPipelinedRegionStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
void |
RestartIndividualStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
void |
RestartAllStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
abstract void |
FailoverStrategy.onTaskFailure(Execution taskExecution,
Throwable cause)
Called by the execution graph when a task failure occurs.
|
Modifier and Type | Method and Description |
---|---|
Execution |
SimpleSlot.getExecutedVertex()
Gets the task execution attempt currently executed in this slot.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SimpleSlot.setExecutedVertex(Execution executedVertex)
Atomically sets the executed vertex, if no vertex has been assigned to this slot so far.
|
Modifier and Type | Method and Description |
---|---|
Execution |
ScheduledUnit.getTaskToExecute() |
Constructor and Description |
---|
ScheduledUnit(Execution task) |
ScheduledUnit(Execution task,
SlotSharingGroup sharingUnit) |
ScheduledUnit(Execution task,
SlotSharingGroup sharingUnit,
CoLocationConstraint locationConstraint) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.