public interface InputConsumableDecider
InputConsumableDecideris responsible for determining whether the input of an executionVertex or a consumed partition group is consumable.
|Modifier and Type||Interface and Description|
|Modifier and Type||Method and Description|
Determining whether the consumed partition group is consumable based on finished producers.
Determining whether the input of an execution vertex is consumable.
boolean isInputConsumable(SchedulingExecutionVertex executionVertex, Set<ExecutionVertexID> verticesToSchedule, Map<ConsumedPartitionGroup,Boolean> consumableStatusCache)
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
ConsumedPartitionGroupconsumable status. This is to avoid repetitive computation.
boolean isConsumableBasedOnFinishedProducers(ConsumedPartitionGroup consumedPartitionGroup)
consumedPartitionGroup- to be determined whether it is consumable.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.