VertexParallelismDecider is responsible for determining the parallelism of a job vertex,
based on the size of the consumed blocking results.
This scheduler decides the parallelism of JobVertex according to the data volume it consumes.
The blocking result info, which will be used to calculate the vertex parallelism.
Default implementation of
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.