Class and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
Class and Description |
---|
InternalFailuresListener
This interface enables subscribing to failures that are detected from the JobMaster side (e.g.,
from within the
ExecutionGraph ). |
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 and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
Class and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
SchedulerNG
Interface for scheduling Flink jobs.
|
SchedulerNGFactory
Factory for
SchedulerNG . |
Class and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
Class and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
Class and Description |
---|
DeploymentOption
Deployment option which indicates whether the task should notify master when its data is
available.
|
ExecutionGraphFactory
Factory for creating an
ExecutionGraph . |
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
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.
|
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. |
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.
|
SchedulerBase
Base class which can be used to implement
SchedulerNG . |
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.
|
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 and Description |
---|
ExecutionGraphFactory
Factory for creating an
ExecutionGraph . |
ExecutionGraphHandler
Handler for the
ExecutionGraph which offers some common operations. |
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
OperatorCoordinatorHandler
Handler for the
OperatorCoordinators . |
SchedulerNG
Interface for scheduling Flink jobs.
|
SchedulerNGFactory
Factory for
SchedulerNG . |
VertexParallelismStore
Contains the max parallelism per vertex, along with metadata about how these maxes were
calculated.
|
Class and Description |
---|
SchedulerOperations
Component which is used by
SchedulingStrategy to commit scheduling decisions. |
Class and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
Class and Description |
---|
ExecutionGraphInfo
ExecutionGraphInfo serves as a composite class that provides different ExecutionGraph -related information. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.