Class and Description |
---|
SchedulerNGFactory
Factory for
SchedulerNG . |
Class and Description |
---|
SchedulerNGFactory
Factory for
SchedulerNG . |
Class and Description |
---|
DeploymentOption
Deployment option which indicates whether the task should send scheduleOrUpdateConsumer message to master.
|
ExecutionSlotAllocator
Component responsible for assigning slots to a collection of
Execution . |
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.
|
InputsLocationsRetriever
Component to retrieve the inputs locations of a
Execution . |
LegacyScheduler
A scheduler that delegates to the scheduling logic in the
ExecutionGraph . |
SchedulerNG
Interface for scheduling Flink jobs.
|
SchedulerNGFactory
Factory for
SchedulerNG . |
SlotExecutionVertexAssignment
The slot assignment for a
ExecutionVertex . |
Class and Description |
---|
SchedulerOperations
Component which is used by
SchedulingStrategy to commit scheduling decisions. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.