public interface VertexParallelismDecider
VertexParallelismDecideris responsible for determining the parallelism of a job vertex, based on the size of the consumed blocking results.
|Modifier and Type||Method and Description|
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.