Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertex.getID() |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<?> |
AdaptedRestartPipelinedRegionStrategyNG.cancelTasks(Set<ExecutionVertexID> vertices) |
protected void |
AdaptedRestartPipelinedRegionStrategyNG.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
FailoverVertex.getExecutionVertexID()
Returns the ID of this vertex.
|
Modifier and Type | Method and Description |
---|---|
Set<ExecutionVertexID> |
FailoverRegion.getAllExecutionVertexIDs()
Returns IDs of all vertices in this region.
|
Set<ExecutionVertexID> |
FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> |
RestartPipelinedRegionStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> |
FailureHandlingResult.getVerticesToRestart()
Returns the tasks to restart.
|
Modifier and Type | Method and Description |
---|---|
FailoverRegion |
RestartPipelinedRegionStrategy.getFailoverRegion(ExecutionVertexID vertexID)
Returns the failover region that contains the given execution vertex.
|
FailureHandlingResult |
ExecutionFailureHandler.getFailureHandlingResult(ExecutionVertexID failedTask,
Throwable cause)
Return result of failure handling.
|
Set<ExecutionVertexID> |
FailoverStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Set<ExecutionVertexID> |
RestartPipelinedRegionStrategy.getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
Modifier and Type | Method and Description |
---|---|
static FailureHandlingResult |
FailureHandlingResult.restartable(Set<ExecutionVertexID> verticesToRestart,
long restartDelayMS)
Creates a result of a set of tasks to restart to recover from the failure.
|
Modifier and Type | Method and Description |
---|---|
Set<ExecutionVertexID> |
PipelinedRegion.getExecutionVertexIds() |
Iterator<ExecutionVertexID> |
PipelinedRegion.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
PipelinedRegion.contains(ExecutionVertexID executionVertexId) |
static PipelinedRegion |
PipelinedRegion.from(ExecutionVertexID... executionVertexIds) |
List<IntermediateResultPartitionID> |
PartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
List<IntermediateResultPartitionID> |
NotReleasingPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<IntermediateResultPartitionID> |
RegionPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
void |
PartitionReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID)
Calling this method informs the strategy that a vertex is no longer in finished state, e.g.,
when a vertex is re-executed.
|
void |
NotReleasingPartitionReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexID) |
void |
RegionPartitionReleaseStrategy.vertexUnfinished(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
static PipelinedRegion |
PipelinedRegion.from(Set<ExecutionVertexID> executionVertexIds) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
ExecutionVertexVersion.getExecutionVertexId() |
ExecutionVertexID |
ExecutionVertexSchedulingRequirements.getExecutionVertexId()
|
ExecutionVertexID |
ExecutionVertexDeploymentOption.getExecutionVertexId() |
ExecutionVertexID |
SlotExecutionVertexAssignment.getExecutionVertexId() |
Modifier and Type | Method and Description |
---|---|
Collection<Collection<ExecutionVertexID>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) |
Collection<Collection<ExecutionVertexID>> |
InputsLocationsRetriever.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)
Get the producers of the result partitions consumed by an execution.
|
Set<ExecutionVertexID> |
ExecutionVertexVersioner.getUnmodifiedExecutionVertices(Set<ExecutionVertexVersion> executionVertexVersions) |
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultExecutionSlotAllocator.cancel(ExecutionVertexID executionVertexId) |
void |
ExecutionSlotAllocator.cancel(ExecutionVertexID executionVertexId)
Cancel an ongoing slot request.
|
Collection<Collection<ExecutionVertexID>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId) |
Collection<Collection<ExecutionVertexID>> |
InputsLocationsRetriever.getConsumedResultPartitionsProducers(ExecutionVertexID executionVertexId)
Get the producers of the result partitions consumed by an execution.
|
Optional<CompletableFuture<TaskManagerLocation>> |
ExecutionGraphToInputsLocationsRetrieverAdapter.getTaskManagerLocation(ExecutionVertexID executionVertexId) |
Optional<CompletableFuture<TaskManagerLocation>> |
InputsLocationsRetriever.getTaskManagerLocation(ExecutionVertexID executionVertexId)
Get the task manager location future for an execution.
|
ExecutionVertexVersion |
ExecutionVertexVersioner.recordModification(ExecutionVertexID executionVertexId) |
ExecutionVertexSchedulingRequirements.Builder |
ExecutionVertexSchedulingRequirements.Builder.withExecutionVertexId(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
Map<ExecutionVertexID,ExecutionVertexVersion> |
ExecutionVertexVersioner.recordVertexModifications(Collection<ExecutionVertexID> vertices) |
Constructor and Description |
---|
ExecutionVertexDeploymentOption(ExecutionVertexID executionVertexId,
DeploymentOption deploymentOption) |
SlotExecutionVertexAssignment(ExecutionVertexID executionVertexId,
CompletableFuture<LogicalSlot> logicalSlotFuture) |
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingExecutionVertex> |
ExecutionGraphToSchedulingTopologyAdapter.getVertex(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexID |
SchedulingExecutionVertex.getId()
Gets id of the execution vertex.
|
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingExecutionVertex> |
SchedulingTopology.getVertex(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
default SchedulingExecutionVertex |
SchedulingTopology.getVertexOrThrow(ExecutionVertexID executionVertexId)
Looks up the
SchedulingExecutionVertex for the given ExecutionVertexID . |
void |
SchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState)
Called whenever an
Execution changes its state. |
void |
EagerSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
void |
LazyFromSourcesSchedulingStrategy.onExecutionStateChange(ExecutionVertexID executionVertexId,
ExecutionState executionState) |
void |
SchedulingStrategy.onPartitionConsumable(ExecutionVertexID executionVertexId,
ResultPartitionID resultPartitionId)
Called whenever an
IntermediateResultPartition becomes consumable. |
void |
EagerSchedulingStrategy.onPartitionConsumable(ExecutionVertexID executionVertexId,
ResultPartitionID resultPartitionId) |
void |
LazyFromSourcesSchedulingStrategy.onPartitionConsumable(ExecutionVertexID executionVertexId,
ResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart)
Called whenever vertices need to be restarted (due to task failure).
|
void |
EagerSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
void |
LazyFromSourcesSchedulingStrategy.restartTasks(Set<ExecutionVertexID> verticesToRestart) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.