Modifier and Type | Class and Description |
---|---|
class |
ApplicationClusterEntryPoint
Base class for cluster entry points targeting executing applications in "Application Mode".
|
Modifier and Type | Class and Description |
---|---|
class |
StandaloneApplicationClusterEntryPoint
An
ApplicationClusterEntryPoint which is started with a job in a predefined location. |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesApplicationClusterEntrypoint
An
ApplicationClusterEntryPoint for Kubernetes. |
class |
KubernetesSessionClusterEntrypoint
Entry point for a Kubernetes session cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointsCleaner
Delegate class responsible for checkpoints cleaning and counting the number of checkpoints yet to
clean.
|
Modifier and Type | Class and Description |
---|---|
class |
Dispatcher
Base class for the Dispatcher component.
|
class |
DispatcherRestEndpoint
REST endpoint for the
Dispatcher component. |
class |
MiniDispatcher
Mini Dispatcher which is instantiated as the dispatcher component by the
JobClusterEntrypoint . |
class |
StandaloneDispatcher
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointResourcesCleanupRunner
CheckpointResourcesCleanupRunner implements JobManagerRunner in a way, that only
the checkpoint-related resources are instantiated. |
Modifier and Type | Interface and Description |
---|---|
static interface |
AbstractDispatcherLeaderProcess.DispatcherGatewayService
An accessor of the
DispatcherGateway . |
interface |
DispatcherRunner
The
DispatcherRunner encapsulates how a Dispatcher is being executed. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultDispatcherGatewayService
A facade over the
Dispatcher that exposes specific functionality. |
class |
DefaultDispatcherRunner
Runner for the
Dispatcher which is responsible for
the leader election. |
Modifier and Type | Class and Description |
---|---|
class |
ClusterEntrypoint
Base class for the Flink cluster entry points.
|
class |
JobClusterEntrypoint
Deprecated.
Per-job mode has been deprecated in Flink 1.15 and will be removed in the future.
Please use application mode instead.
|
class |
SessionClusterEntrypoint
Base class for session cluster entry points.
|
class |
StandaloneSessionClusterEntrypoint
Entry point for the standalone session cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
DispatcherResourceManagerComponent
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobManagerRunner
Interface for a runner which executes a
JobMaster . |
interface |
JobMasterService
Interface which specifies the JobMaster service.
|
interface |
JobMasterServiceProcess
JobMasterServiceProcess is responsible for running a
JobMasterService . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultJobMasterServiceProcess
Default
JobMasterServiceProcess which is responsible for creating and running a JobMasterService . |
class |
JobMaster
JobMaster implementation.
|
class |
JobMasterServiceLeadershipRunner
Leadership runner for the
JobMasterServiceProcess . |
static class |
JobMasterServiceProcess.WaitingForLeadership |
class |
MiniDispatcherRestEndpoint
REST endpoint for the
JobClusterEntrypoint . |
Modifier and Type | Class and Description |
---|---|
class |
MetricQueryService
The MetricQueryService creates a key-value representation of all metrics currently registered
with Flink when queried.
|
Modifier and Type | Class and Description |
---|---|
class |
MiniCluster
MiniCluster to execute Flink jobs locally.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ResourceManagerService
Service that maintains lifecycle of
ResourceManager . |
Modifier and Type | Class and Description |
---|---|
class |
ResourceManager<WorkerType extends ResourceIDRetrievable>
ResourceManager implementation.
|
class |
ResourceManagerServiceImpl
Default implementation of
ResourceManagerService . |
class |
StandaloneResourceManager
A standalone implementation of the resource manager.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveResourceManager<WorkerType extends ResourceIDRetrievable>
An active implementation of
ResourceManager . |
Modifier and Type | Interface and Description |
---|---|
interface |
RestService
Rest service interface.
|
Modifier and Type | Class and Description |
---|---|
class |
RestClient
This client is the counter-part to the
RestServerEndpoint . |
class |
RestServerEndpoint
An abstract class for netty-based REST server endpoints.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHandler<T extends RestfulGateway,R extends RequestBody,M extends MessageParameters>
Super class for netty-based handlers that work with
RequestBody . |
class |
AbstractRestHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
Super class for netty-based handlers that work with
RequestBody s and ResponseBody s. |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractAsynchronousOperationHandlers.StatusHandler<T extends RestfulGateway,V,M extends MessageParameters>
Handler which will be polled to retrieve the asynchronous operation's result.
|
protected class |
AbstractAsynchronousOperationHandlers.TriggerHandler<T extends RestfulGateway,B extends RequestBody,M extends MessageParameters>
Handler which is responsible for triggering an asynchronous operation.
|
class |
CompletedOperationCache<K extends OperationKey,R>
Cache to manage ongoing operations.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractJobManagerFileHandler<M extends MessageParameters>
Base class for serving files from the JobManager.
|
class |
ClusterConfigHandler
Handler which serves the cluster's configuration.
|
class |
ClusterOverviewHandler
Handler which returns the cluster overview information with version.
|
class |
DashboardConfigHandler
Handler which returns the dashboard configuration.
|
class |
JobManagerCustomLogHandler
Rest handler which serves the custom log file from JobManager.
|
class |
JobManagerLogFileHandler
Rest handler which serves the log files from JobManager.
|
class |
JobManagerLogListHandler
Handler which serves detailed JobManager log list information.
|
class |
JobManagerThreadDumpHandler
Rest handler which serves the thread dump info from the JobManager.
|
class |
ShutdownHandler
REST handler which allows to shut down the cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterDataSetDeleteHandlers.ClusterDataSetDeleteStatusHandler
StatusHandler implementation for the cluster data set delete operation. |
class |
ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler
TriggerHandler implementation for the cluster data set delete operation. |
class |
ClusterDataSetListHandler
Handler for
ClusterDataSetListHeaders . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAccessExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
AbstractAccessExecutionGraphHandler handles requests that require accessing the job's
AccessExecutionGraph . |
class |
AbstractExecutionGraphHandler<R extends ResponseBody,M extends JobMessageParameters>
Base class for all
ExecutionGraphInfo based REST handlers. |
class |
AbstractJobVertexHandler<R extends ResponseBody,M extends JobVertexMessageParameters>
Base class for request handlers whose response depends on a specific job vertex (defined via the
"
JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the
"JobIDPathParameter.KEY " parameter). |
class |
AbstractSubtaskAttemptHandler<R extends ResponseBody,M extends SubtaskAttemptMessageParameters>
Base class for request handlers whose response depends on a specific attempt (defined via the
"
SubtaskAttemptPathParameter.KEY " of a specific subtask (defined via the "SubtaskIndexPathParameter.KEY " in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY " parameter). |
class |
AbstractSubtaskHandler<R extends ResponseBody,M extends SubtaskMessageParameters>
Base class for request handlers whose response depends on a specific subtask (defined via the
"
SubtaskIndexPathParameter.KEY " in a specific job vertex, (defined via the "JobVertexIdPathParameter.KEY " parameter) in a specific job, defined via (defined via the "JobIDPathParameter.KEY " parameter). |
class |
JobAccumulatorsHandler
Request handler that returns the aggregated accumulators of a job.
|
class |
JobCancellationHandler
Request handler for the cancel and stop request.
|
class |
JobConfigHandler
Handler serving the job configuration.
|
class |
JobDetailsHandler
Handler returning the details for the specified job.
|
class |
JobExceptionsHandler
Handler serving the job exceptions.
|
class |
JobExecutionResultHandler
Returns the
JobExecutionResult for a given JobID . |
class |
JobIdsHandler
Handler for job IDs.
|
class |
JobPlanHandler
Handler serving the job execution plan.
|
class |
JobsOverviewHandler
Overview handler for jobs.
|
class |
JobSubmitHandler
This handler can be used to submit jobs to a Flink cluster.
|
class |
JobVertexAccumulatorsHandler
Request handler for the job vertex accumulators.
|
class |
JobVertexBackPressureHandler
Request handler for the job vertex back pressure.
|
class |
JobVertexDetailsHandler
Request handler for the job vertex details.
|
class |
JobVertexFlameGraphHandler
Request handler for the job vertex Flame Graph.
|
class |
JobVertexTaskManagersHandler
A request handler that provides the details of a job vertex, including id, name, and the runtime
and metrics of all its subtasks aggregated by TaskManager.
|
class |
SubtaskCurrentAttemptDetailsHandler
Request handler providing details about a single task execution attempt.
|
class |
SubtaskExecutionAttemptAccumulatorsHandler
Request handler for the subtask execution attempt accumulators.
|
class |
SubtaskExecutionAttemptDetailsHandler
Handler of specific sub task execution attempt.
|
class |
SubtasksAllAccumulatorsHandler
Request handler for the subtasks all accumulators.
|
class |
SubtasksTimesHandler
Request handler for the subtasks times info.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCheckpointHandler<R extends ResponseBody,M extends CheckpointMessageParameters>
Base class for checkpoint related REST handler.
|
class |
CheckpointConfigHandler
Handler which serves the checkpoint configuration.
|
class |
CheckpointingStatisticsHandler
Handler which serves the checkpoint statistics.
|
class |
CheckpointStatisticDetailsHandler
REST handler which returns the details for a checkpoint.
|
class |
TaskCheckpointStatisticDetailsHandler
REST handler which serves checkpoint statistics for subtasks.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientCoordinationHandler
Handler that receives the coordination requests from the client and returns the response from the
coordinator.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAggregatingMetricsHandler<P extends AbstractAggregatedMetricsParameters<?>>
Abstract request handler for querying aggregated metrics.
|
class |
AbstractMetricsHandler<M extends MessageParameters>
Request handler that returns for a given task a list of all available metrics or the values for a
set of metrics.
|
class |
AggregatingJobsMetricsHandler
Request handler that returns, aggregated across jobs, a list of all available metrics or the
values for a set of metrics.
|
class |
AggregatingSubtasksMetricsHandler
Request handler that returns, aggregated across subtasks, a list of all available metrics or the
values for a set of metrics.
|
class |
AggregatingTaskManagersMetricsHandler
Request handler that returns, aggregated across task managers, a list of all available metrics or
the values for a set of metrics.
|
class |
JobManagerMetricsHandler
Handler that returns JobManager metrics.
|
class |
JobMetricsHandler
Request handler that returns for a given job a list of all available metrics or the values for a
set of metrics.
|
class |
JobVertexMetricsHandler
Deprecated.
This class is subsumed by
SubtaskMetricsHandler and is only kept for
backwards-compatibility. |
class |
JobVertexWatermarksHandler
Handler that returns the watermarks given a
JobID and JobVertexID . |
class |
SubtaskMetricsHandler
Handler that returns subtask metrics.
|
class |
TaskManagerMetricsHandler
Handler that returns TaskManager metrics.
|
Modifier and Type | Class and Description |
---|---|
class |
RescalingHandlers.RescalingStatusHandler
Handler which reports the status of the rescaling operation.
|
class |
RescalingHandlers.RescalingTriggerHandler
Handler which triggers the rescaling of the specified job.
|
Modifier and Type | Class and Description |
---|---|
class |
SavepointDisposalHandlers.SavepointDisposalStatusHandler
StatusHandler implementation for the savepoint disposal operation. |
class |
SavepointDisposalHandlers.SavepointDisposalTriggerHandler
TriggerHandler implementation for the savepoint disposal operation. |
static class |
SavepointHandlers.SavepointStatusHandler
HTTP handler to query for the status of the savepoint.
|
class |
SavepointHandlers.SavepointTriggerHandler
HTTP handler to trigger savepoints.
|
class |
SavepointHandlers.StopWithSavepointHandler
HTTP handler to stop a job with a savepoint.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractResourceManagerHandler<T extends RestfulGateway,R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
Base class for REST handlers which need access to the
ResourceManager . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTaskManagerFileHandler<M extends TaskManagerMessageParameters>
Base class for serving files from the
TaskExecutor . |
class |
TaskManagerCustomLogHandler
Rest handler which serves the custom file of the
TaskExecutor . |
class |
TaskManagerDetailsHandler
Handler which serves detailed TaskManager information.
|
class |
TaskManagerLogFileHandler
Rest handler which serves the log files from
TaskExecutor . |
class |
TaskManagerLogListHandler
Handler which serves detailed TaskManager log list information.
|
class |
TaskManagersHandler
Returns an overview over all registered TaskManagers of the cluster.
|
class |
TaskManagerStdoutFileHandler
Rest handler which serves the stdout file of the
TaskExecutor . |
class |
TaskManagerThreadDumpHandler
Rest handler which serves the thread dump info from a
TaskExecutor . |
Modifier and Type | Class and Description |
---|---|
class |
FencedRpcEndpoint<F extends Serializable>
Base class for fenced
RpcEndpoint . |
class |
PermanentlyFencedRpcEndpoint<F extends Serializable>
FencedRpcEndpoint which is fenced with a fencing token which is bound to the lifetime of
the rpc endpoint. |
class |
RpcEndpoint
Base class for RPC endpoints.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SchedulerNG
Interface for scheduling Flink jobs.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultScheduler
The future default scheduler.
|
class |
SchedulerBase
Base class which can be used to implement
SchedulerNG . |
Modifier and Type | Class and Description |
---|---|
class |
AdaptiveScheduler
A
SchedulerNG implementation that uses the declarative resource management and
automatically adapts the parallelism in case not enough resource could be acquired to run at the
configured parallelism, as described in FLIP-160. |
Modifier and Type | Class and Description |
---|---|
class |
AdaptiveBatchScheduler
This scheduler decides the parallelism of JobVertex according to the data volume it consumes.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
TaskManagerRunner.TaskExecutorService |
Modifier and Type | Class and Description |
---|---|
class |
TaskExecutor
TaskExecutor implementation.
|
class |
TaskExecutorToServiceAdapter
Simple adapter for
TaskExecutor to adapt to TaskManagerRunner.TaskExecutorService . |
Modifier and Type | Interface and Description |
---|---|
interface |
TaskSlotTable<T extends TaskSlotPayload>
Container for multiple
TaskSlot instances. |
Modifier and Type | Class and Description |
---|---|
class |
TaskSlot<T extends TaskSlotPayload>
Container for multiple
tasks belonging to the same slot. |
class |
TaskSlotTableImpl<T extends TaskSlotPayload>
Default implementation of
TaskSlotTable . |
Modifier and Type | Interface and Description |
---|---|
interface |
WebMonitorExtension
Interface for
WebMonitorEndpoint extensions. |
Modifier and Type | Class and Description |
---|---|
class |
WebMonitorEndpoint<T extends RestfulGateway>
Rest endpoint which serves the web frontend REST calls.
|
static class |
WebMonitorExtension.EmptyWebMonitorExtension
Empty web monitor extension which can be used as a null object.
|
class |
WebSubmissionExtension
Container for the web submission handlers.
|
Modifier and Type | Class and Description |
---|---|
class |
JarDeleteHandler
Handles requests for deletion of jars.
|
class |
JarListHandler
Handle request for listing uploaded jars.
|
class |
JarPlanHandler
This handler handles requests to fetch the plan for a jar.
|
class |
JarRunHandler
Handler to submit jobs uploaded via the Web UI.
|
class |
JarUploadHandler
Handles .jar file uploads.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClusterController
Controller for interacting with a cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
YarnApplicationClusterEntryPoint
An
ApplicationClusterEntryPoint for Yarn. |
class |
YarnJobClusterEntrypoint
Deprecated.
Per-mode has been deprecated in Flink 1.15 and will be removed in the future. Please
use application mode instead.
|
class |
YarnSessionClusterEntrypoint
Entry point for Yarn session clusters.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.