public class RestartPipelinedRegionFailoverStrategy extends Object implements FailoverStrategy
Modifier and Type | Class and Description |
---|---|
static class |
RestartPipelinedRegionFailoverStrategy.Factory
The factory to instantiate
RestartPipelinedRegionFailoverStrategy . |
Constructor and Description |
---|
RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology)
Creates a new failover strategy to restart pipelined regions that works on the given
topology.
|
RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Creates a new failover strategy to restart pipelined regions that works on the given
topology.
|
Modifier and Type | Method and Description |
---|---|
SchedulingPipelinedRegion |
getFailoverRegion(ExecutionVertexID vertexID)
Returns the failover region that contains the given execution vertex.
|
Set<ExecutionVertexID> |
getTasksNeedingRestart(ExecutionVertexID executionVertexId,
Throwable cause)
Returns a set of IDs corresponding to the set of vertices that should be restarted.
|
@VisibleForTesting public RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology)
topology
- containing info about all the vertices and result partitionspublic RestartPipelinedRegionFailoverStrategy(SchedulingTopology topology, ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
topology
- containing info about all the vertices and result partitionsresultPartitionAvailabilityChecker
- helps to query result partition availabilitypublic Set<ExecutionVertexID> getTasksNeedingRestart(ExecutionVertexID executionVertexId, Throwable cause)
getTasksNeedingRestart
in interface FailoverStrategy
executionVertexId
- ID of the failed taskcause
- cause of the failure@VisibleForTesting public SchedulingPipelinedRegion getFailoverRegion(ExecutionVertexID vertexID)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.