Uses of Interface
org.apache.flink.runtime.scheduler.SchedulerOperations
-
Packages that use SchedulerOperations Package Description org.apache.flink.runtime.scheduler org.apache.flink.runtime.scheduler.adaptivebatch org.apache.flink.runtime.scheduler.strategy -
-
Uses of SchedulerOperations in org.apache.flink.runtime.scheduler
Classes in org.apache.flink.runtime.scheduler that implement SchedulerOperations Modifier and Type Class Description classDefaultSchedulerThe future default scheduler. -
Uses of SchedulerOperations in org.apache.flink.runtime.scheduler.adaptivebatch
Classes in org.apache.flink.runtime.scheduler.adaptivebatch that implement SchedulerOperations Modifier and Type Class Description classAdaptiveBatchSchedulerThis scheduler decides the parallelism of JobVertex according to the data volume it consumes.classSpeculativeSchedulerThe speculative scheduler. -
Uses of SchedulerOperations in org.apache.flink.runtime.scheduler.strategy
Methods in org.apache.flink.runtime.scheduler.strategy with parameters of type SchedulerOperations Modifier and Type Method Description SchedulingStrategyPipelinedRegionSchedulingStrategy.Factory. createInstance(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology)SchedulingStrategySchedulingStrategyFactory. createInstance(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology)SchedulingStrategyVertexwiseSchedulingStrategy.Factory. createInstance(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology)Constructors in org.apache.flink.runtime.scheduler.strategy with parameters of type SchedulerOperations Constructor Description PipelinedRegionSchedulingStrategy(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology)VertexwiseSchedulingStrategy(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology, InputConsumableDecider.Factory inputConsumableDeciderFactory)
-