Uses of Interface
org.apache.flink.runtime.scheduler.SchedulingTopologyListener
-
-
Uses of SchedulingTopologyListener in org.apache.flink.runtime.executiongraph.failover.partitionrelease
Classes in org.apache.flink.runtime.executiongraph.failover.partitionrelease that implement SchedulingTopologyListener Modifier and Type Class Description class
RegionPartitionGroupReleaseStrategy
Releases blocking intermediate result partitions that are incident to aSchedulingPipelinedRegion
, as soon as the region's execution vertices are finished. -
Uses of SchedulingTopologyListener in org.apache.flink.runtime.scheduler.adapter
Methods in org.apache.flink.runtime.scheduler.adapter with parameters of type SchedulingTopologyListener Modifier and Type Method Description void
DefaultExecutionTopology. registerSchedulingTopologyListener(SchedulingTopologyListener listener)
-
Uses of SchedulingTopologyListener in org.apache.flink.runtime.scheduler.strategy
Classes in org.apache.flink.runtime.scheduler.strategy that implement SchedulingTopologyListener Modifier and Type Class Description class
VertexwiseSchedulingStrategy
SchedulingStrategy
instance which schedules tasks in granularity of vertex (which indicates this strategy only supports batch jobs).Methods in org.apache.flink.runtime.scheduler.strategy with parameters of type SchedulingTopologyListener Modifier and Type Method Description void
SchedulingTopology. registerSchedulingTopologyListener(SchedulingTopologyListener listener)
Register a scheduling topology listener.
-