Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease |
Modifier and Type | Method and Description |
---|---|
PartitionGroupReleaseStrategy |
DefaultExecutionGraph.getPartitionGroupReleaseStrategy() |
PartitionGroupReleaseStrategy |
InternalExecutionGraphAccessor.getPartitionGroupReleaseStrategy() |
Modifier and Type | Class and Description |
---|---|
class |
NotReleasingPartitionGroupReleaseStrategy
Does not release intermediate result partitions during job execution.
|
class |
RegionPartitionGroupReleaseStrategy
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 |
---|---|
PartitionGroupReleaseStrategy |
PartitionGroupReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionGroupReleaseStrategy |
NotReleasingPartitionGroupReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
PartitionGroupReleaseStrategy |
RegionPartitionGroupReleaseStrategy.Factory.createInstance(SchedulingTopology schedulingStrategy) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.