public interface VertexParallelismDecider
VertexParallelismDecider
is responsible for determining the parallelism of a job vertex,
based on the size of the consumed blocking results.Modifier and Type | Method and Description |
---|---|
int |
decideParallelismForVertex(List<BlockingResultInfo> consumedResults)
Computing the parallelism.
|
int decideParallelismForVertex(List<BlockingResultInfo> consumedResults)
consumedResults
- The information of consumed blocking results.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.