Uses of Package
org.apache.flink.runtime.scheduler.adaptivebatch

Packages that use org.apache.flink.runtime.scheduler.adaptivebatch

Package	Description
org.apache.flink.runtime.scheduler.adaptivebatch

Classes in org.apache.flink.runtime.scheduler.adaptivebatch used by org.apache.flink.runtime.scheduler.adaptivebatch

Class and Description
AdaptiveBatchScheduler This scheduler decides the parallelism of JobVertex according to the data volume it consumes.
BlockingResultInfo The blocking result info, which will be used to calculate the vertex parallelism.
VertexParallelismDecider VertexParallelismDecider is responsible for determining the parallelism of a job vertex, based on the size of the consumed blocking results.