Interface | Description |
---|---|
ExecutionSlotAllocator |
Component responsible for assigning slots to a collection of
Execution . |
InputsLocationsRetriever |
Component to retrieve the inputs locations of a
Execution . |
SchedulerNG |
Interface for scheduling Flink jobs.
|
SchedulerNGFactory |
Factory for
SchedulerNG . |
SchedulerOperations |
Component which is used by
SchedulingStrategy to commit scheduling decisions. |
Class | Description |
---|---|
DefaultExecutionSlotAllocator |
Default
ExecutionSlotAllocator which will use SlotProvider to allocate slots and
keep the unfulfilled requests for further cancellation. |
DefaultScheduler |
Stub implementation of the future default scheduler.
|
DefaultSchedulerFactory |
Factory for
DefaultScheduler . |
DeploymentOption |
Deployment option which indicates whether the task should send scheduleOrUpdateConsumer message to master.
|
ExecutionGraphToInputsLocationsRetrieverAdapter |
An implementation of
InputsLocationsRetriever based on the ExecutionGraph . |
ExecutionVertexDeploymentOption |
Component that stores the task need to be scheduled and the option for deployment.
|
ExecutionVertexSchedulingRequirements |
The requirements for scheduling a
ExecutionVertex . |
ExecutionVertexSchedulingRequirements.Builder |
Builder for
ExecutionVertexSchedulingRequirements . |
ExecutionVertexVersion |
This class helps to record version of an execution vertex.
|
ExecutionVertexVersioner |
Records modifications of
ExecutionVertices , and allows
for checking whether a vertex was modified. |
LegacyScheduler |
A scheduler that delegates to the scheduling logic in the
ExecutionGraph . |
LegacySchedulerFactory |
Factory for
LegacyScheduler . |
SlotExecutionVertexAssignment |
The slot assignment for a
ExecutionVertex . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.