Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover.flip1 |
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() |
Constructor and Description |
---|
RestartPipelinedRegionStrategy(FailoverTopology topology,
ResultPartitionAvailabilityChecker resultPartitionAvailabilityChecker)
Creates a new failover strategy to restart pipelined regions that works on the given topology.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.