Interface | Description |
---|---|
FailoverEdge |
A connection between
FailoverVertices . |
FailoverStrategy |
New interface for failover strategies.
|
FailoverStrategy.Factory |
The factory to instantiate
FailoverStrategy . |
FailoverTopology |
Represents a topology.
|
FailoverVertex |
Represents an ExecutionVertex.
|
RestartBackoffTimeStrategy |
Strategy to decide whether to restart failed tasks and the delay to do the restarting.
|
RestartBackoffTimeStrategy.Factory |
The factory to instantiate
RestartBackoffTimeStrategy . |
ResultPartitionAvailabilityChecker |
This checker helps to query result partition availability.
|
Class | Description |
---|---|
ExecutionFailureHandler |
This handler deals with task failures to return a
FailureHandlingResult which contains tasks
to restart to recover from failures. |
FailoverRegion |
FailoverRegion is a subset of all the vertices in the job topology.
|
FailureHandlingResult |
Result containing the tasks to restart upon a task failure.
|
FailureRateRestartBackoffTimeStrategy |
Restart strategy which can restart when failure rate is not exceeded.
|
FailureRateRestartBackoffTimeStrategy.FailureRateRestartBackoffTimeStrategyFactory |
The factory for creating
FailureRateRestartBackoffTimeStrategy . |
FixedDelayRestartBackoffTimeStrategy |
Restart strategy which tries to restart a fixed number of times with a fixed backoff time in between.
|
FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory |
The factory for creating
FixedDelayRestartBackoffTimeStrategy . |
PipelinedRegionComputeUtil |
Utility for computing pipelined regions.
|
RestartPipelinedRegionStrategy |
A failover strategy that proposes to restart involved regions when a vertex fails.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.