Package | Description |
---|---|
org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease |
Modifier and Type | Class and Description |
---|---|
class |
NotReleasingPartitionReleaseStrategy
Does not release intermediate result partitions during job execution.
|
class |
RegionPartitionReleaseStrategy
Releases blocking intermediate result partitions that are incident to a
PipelinedRegion ,
as soon as the region's execution vertices are finished. |
Modifier and Type | Method and Description |
---|---|
PartitionReleaseStrategy |
PartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy,
FailoverTopology failoverTopology) |
PartitionReleaseStrategy |
NotReleasingPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy,
FailoverTopology failoverTopology) |
PartitionReleaseStrategy |
RegionPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy,
FailoverTopology failoverTopology) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.