Package | Description |
---|---|
org.apache.flink.runtime.scheduler.adaptive | |
org.apache.flink.runtime.scheduler.adaptive.allocator |
Class and Description |
---|
JobInformation
Information about the job.
|
JobInformation.VertexInformation
Information about a single vertex.
|
SlotAllocator
Component for calculating the slot requirements and mapping of vertices to slots.
|
SlotSharingSlotAllocator
SlotAllocator implementation that supports slot sharing. |
Class and Description |
---|
FreeSlotFunction
A function for freeing slots.
|
IsSlotAvailableAndFreeFunction
Functional interface for checking whether a slot is available and free.
|
JobInformation
Information about the job.
|
JobInformation.VertexInformation
Information about a single vertex.
|
ReservedSlots
Container for the set of reserved slots for
ExecutionVertexID . |
ReserveSlotFunction
A function for reserving slots.
|
SlotAllocator
Component for calculating the slot requirements and mapping of vertices to slots.
|
SlotSharingSlotAllocator
SlotAllocator implementation that supports slot sharing. |
VertexParallelism
Core result of
SlotAllocator.determineParallelism(JobInformation, Collection) , describing
the parallelism each vertex could be scheduled with. |
VertexParallelismWithSlotSharing
VertexParallelism implementation for the SlotSharingSlotAllocator . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.