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 |
ExecutionAndAllocationFuture.executionAttempt |
Modifier and Type | Method and Description |
---|---|
Execution |
ExecutionVertex.getCurrentExecutionAttempt() |
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 |
---|---|
CompletableFuture<Execution> |
Execution.allocateAndAssignSlotForExecution(SlotProvider slotProvider,
boolean queued,
LocationPreferenceConstraint locationPreferenceConstraint,
Set<AllocationID> allPreviousExecutionGraphAllocationIds,
Time allocationTimeout)
Allocates and assigns a slot obtained from the slot provider to the execution.
|
Collection<CompletableFuture<Execution>> |
ExecutionJobVertex.allocateResourcesForAll(SlotProvider resourceProvider,
boolean queued,
LocationPreferenceConstraint locationPreferenceConstraint,
Set<AllocationID> allPreviousExecutionGraphAllocationIds,
Time allocationTimeout)
Acquires a slot for all the execution vertices of this ExecutionJobVertex.
|
Map<ExecutionAttemptID,Execution> |
ExecutionGraph.getRegisteredExecutions() |
Constructor and Description |
---|
ArchivedExecution(Execution execution) |
ExecutionAndAllocationFuture(Execution executionAttempt,
CompletableFuture<Void> allocationFuture) |
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 |
RestartAllStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
void |
RestartIndividualStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
abstract void |
FailoverStrategy.onTaskFailure(Execution taskExecution,
Throwable cause)
Called by the execution graph when a task failure occurs.
|
void |
RestartPipelinedRegionStrategy.onTaskFailure(Execution taskExecution,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
Execution |
ScheduledUnit.getTaskToExecute() |
Constructor and Description |
---|
ScheduledUnit(Execution task) |
ScheduledUnit(Execution task,
JobVertexID jobVertexId,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId) |
ScheduledUnit(Execution task,
SlotSharingGroupId slotSharingGroupId,
CoLocationConstraint coLocationConstraint) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.