Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adaptivebatch |
Modifier and Type | Method and Description |
---|---|
static BlockingResultInfo |
BlockingResultInfo.createFromIntermediateResult(IntermediateResult intermediateResult) |
Modifier and Type | Method and Description |
---|---|
int |
DefaultVertexParallelismDecider.decideParallelismForVertex(JobVertexID jobVertexId,
List<BlockingResultInfo> consumedResults,
int vertexMaxParallelism) |
int |
VertexParallelismDecider.decideParallelismForVertex(JobVertexID jobVertexId,
List<BlockingResultInfo> consumedResults,
int vertexMaxParallelism)
Computing the parallelism.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.