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
SchedulingPipelinedRegion , as soon as the region's execution vertices are finished. |
Modifier and Type | Method and Description |
---|---|
PartitionReleaseStrategy |
RegionPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionReleaseStrategy |
PartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionReleaseStrategy |
NotReleasingPartitionReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.