org.apache.flink.runtime.scheduler.strategy

Interface InputConsumableDecider

All Known Implementing Classes:

AllFinishedInputConsumableDecider, DefaultInputConsumableDecider, PartialFinishedInputConsumableDecider

public interface InputConsumableDecider

InputConsumableDecider is responsible for determining whether the input of an executionVertex is consumable.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	InputConsumableDecider.Factory Factory for InputConsumableDecider.

Method Summary

Modifier and Type	Method and Description
boolean	isInputConsumable(SchedulingExecutionVertex executionVertex, Set<ExecutionVertexID> verticesToSchedule, Map<ConsumedPartitionGroup,Boolean> consumableStatusCache) Determining whether the input of an execution vertex is consumable.

Method Detail

isInputConsumable

boolean isInputConsumable(SchedulingExecutionVertex executionVertex,
                          Set<ExecutionVertexID> verticesToSchedule,
                          Map<ConsumedPartitionGroup,Boolean> consumableStatusCache)

Determining whether the input of an execution vertex is consumable.

Parameters:

executionVertex - to be determined whether it's input is consumable.

verticesToSchedule - vertices that are not yet scheduled but already decided to be scheduled.

consumableStatusCache - a cache for ConsumedPartitionGroup consumable status. This is to avoid repetitive computation.