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

Class VertexwiseSchedulingStrategy.Factory

java.lang.Object

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

All Implemented Interfaces:

SchedulingStrategyFactory

Enclosing class:

VertexwiseSchedulingStrategy

public static class VertexwiseSchedulingStrategy.Factory
extends Object
implements SchedulingStrategyFactory

The factory for creating VertexwiseSchedulingStrategy.

Constructor Summary

Constructors

Constructor	Description
Factory(InputConsumableDecider.Factory inputConsumableDeciderFactory)

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(InputConsumableDecider.Factory inputConsumableDeciderFactory)

Method Detail

createInstance

public SchedulingStrategy createInstance(SchedulerOperations schedulerOperations,
                                         SchedulingTopology schedulingTopology)

Specified by:

createInstance in interface SchedulingStrategyFactory