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 |
ExecutionGraph.getResultPartitionAvailabilityChecker() |
Modifier and Type | Method and Description |
---|---|
FailoverStrategy |
RestartAllStrategy.Factory.create(FailoverTopology<?,?> topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
FailoverStrategy |
FailoverStrategy.Factory.create(FailoverTopology<?,?> topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Instantiates the
FailoverStrategy . |
FailoverStrategy |
RestartPipelinedRegionStrategy.Factory.create(FailoverTopology<?,?> topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker) |
Constructor and Description |
---|
RestartPipelinedRegionStrategy(FailoverTopology<?,?> 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–2020 The Apache Software Foundation. All rights reserved.