Interface | Description |
---|---|
ExecutionGraphFactory |
Factory for creating an
ExecutionGraph . |
ExecutionSlotAllocator |
Component responsible for assigning slots to a collection of
Execution . |
ExecutionSlotAllocatorFactory |
Interface for
ExecutionSlotAllocator factories. |
InputsLocationsRetriever |
Component to retrieve the inputs locations of a
Execution . |
InternalFailuresListener |
This interface enables subscribing to failures that are detected from the JobMaster side (e.g.,
from within the
ExecutionGraph ). |
MutableVertexParallelismStore |
Mutability extension to the
VertexParallelismStore . |
OperatorCoordinatorHandler |
Handler for the
OperatorCoordinators . |
PreferredLocationsRetriever |
Component to retrieve the preferred locations of an execution vertex.
|
SchedulerNG |
Interface for scheduling Flink jobs.
|
SchedulerNGFactory |
Factory for
SchedulerNG . |
SchedulerOperations |
Component which is used by
SchedulingStrategy to commit scheduling decisions. |
StateLocationRetriever |
Component to retrieve the state location of an execution vertex.
|
SyncPreferredLocationsRetriever |
Component to retrieve the preferred locations of an execution vertex.
|
VertexParallelismInformation |
Manages the parallelism properties for a vertex in the execution graph, as well as how they can
change during runtime.
|
VertexParallelismStore |
Contains the max parallelism per vertex, along with metadata about how these maxes were
calculated.
|
Class | Description |
---|---|
DefaultExecutionGraphFactory |
Default
ExecutionGraphFactory implementation. |
DefaultOperatorCoordinatorHandler |
Default handler for the
OperatorCoordinators . |
DefaultPreferredLocationsRetriever |
Default implementation of
PreferredLocationsRetriever . |
DefaultScheduler |
The future default scheduler.
|
DefaultSchedulerComponents |
Components to create a
DefaultScheduler . |
DefaultSchedulerFactory |
Factory for
DefaultScheduler . |
DefaultVertexParallelismInfo |
A
VertexParallelismInformation implementation that provides common validation. |
DefaultVertexParallelismStore |
Maintains the configured parallelisms for vertices, which should be defined by a scheduler.
|
DeploymentOption |
Deployment option which indicates whether the task should notify master when its data is
available.
|
ExecutionGraphHandler |
Handler for the
ExecutionGraph which offers some common operations. |
ExecutionGraphInfo |
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
ExecutionGraphToInputsLocationsRetrieverAdapter |
An implementation of
InputsLocationsRetriever based on the ExecutionGraph . |
ExecutionVertexDeploymentOption |
Component that stores the task need to be scheduled and the option for deployment.
|
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. |
KvStateHandler |
Handler for common queryable state logic.
|
SchedulerBase |
Base class which can be used to implement
SchedulerNG . |
SchedulerUtils |
Utils class for Flink's scheduler implementations.
|
UpdateSchedulerNgOnInternalFailuresListener |
Calls
SchedulerNG.updateTaskExecutionState(TaskExecutionStateTransition) on task failure. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.