Package org.apache.flink.runtime.scheduler.strategy

Class PipelinedRegionSchedulingStrategy.Factory

java.lang.Object

org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy.Factory

All Implemented Interfaces:

SchedulingStrategyFactory

Enclosing class:

PipelinedRegionSchedulingStrategy

public static class PipelinedRegionSchedulingStrategy.Factory
extends Object
implements SchedulingStrategyFactory

The factory for creating PipelinedRegionSchedulingStrategy.

Constructor Summary

Constructors

Constructor	Description
Factory()

Method Summary

Modifier and Type	Method	Description
SchedulingStrategy	createInstance(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Factory

public Factory()

Method Detail

createInstance

public SchedulingStrategy createInstance(SchedulerOperations schedulerOperations,
                                         SchedulingTopology schedulingTopology)

Specified by:

createInstance in interface SchedulingStrategyFactory