org.apache.flink.runtime.scheduler.strategy

Interface InputConsumableDecider.Factory

All Known Implementing Classes:

AllFinishedInputConsumableDecider.Factory, DefaultInputConsumableDecider.Factory, PartialFinishedInputConsumableDecider.Factory

Enclosing interface:

InputConsumableDecider

public static interface InputConsumableDecider.Factory

Factory for InputConsumableDecider.

Method Summary

Modifier and Type	Method and Description
InputConsumableDecider	createInstance(SchedulingTopology schedulingTopology, java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)

Method Detail

createInstance

InputConsumableDecider createInstance(SchedulingTopology schedulingTopology,
                                      java.util.function.Function<ExecutionVertexID,Boolean> scheduledVertexRetriever)