Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover.flip1 | |
org.apache.flink.runtime.scheduler |
Modifier and Type | Class and Description |
---|---|
class |
ExecutionGraphResultPartitionAvailabilityChecker
A
ResultPartitionAvailabilityChecker which decides the intermediate result partition
availability based on whether the corresponding result partition in the execution graph is
tracked. |
Modifier and Type | Method and Description |
---|---|
ResultPartitionAvailabilityChecker |
DefaultExecutionGraph.getResultPartitionAvailabilityChecker() |
ResultPartitionAvailabilityChecker |
ExecutionGraph.getResultPartitionAvailabilityChecker() |
Modifier and Type | Method and Description |
---|---|
FailoverStrategy |
RestartPipelinedRegionFailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
FailoverStrategy |
RestartAllFailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
FailoverStrategy |
FailoverStrategy.Factory.create(SchedulingTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Instantiates the
FailoverStrategy . |
Constructor and Description |
---|
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 |
---|---|
protected ResultPartitionAvailabilityChecker |
SchedulerBase.getResultPartitionAvailabilityChecker() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.