Class | Description |
---|---|
ClusterConfiguration |
Configuration class which contains the parsed command line arguments for the
ClusterEntrypoint . |
ClusterConfigurationParserFactory |
Parser factory which generates a
ClusterConfiguration from the given list of command line
arguments. |
ClusterEntrypoint |
Base class for the Flink cluster entry points.
|
ClusterEntryPointExceptionUtils |
Exception utils to handle and enrich exceptions occurring in the ClusterEntrypoint.
|
ClusterEntrypointUtils |
Utility class for
ClusterEntrypoint . |
ClusterInformation |
Information about the cluster which is shared with the cluster components.
|
DeterminismEnvelope<T> |
Envelope that carries whether the wrapped value is deterministic or not.
|
DynamicParametersConfigurationParserFactory |
DynamicParametersConfigurationParserFactory can be used to extract the dynamic parameters
from command line. |
EntrypointClusterConfiguration |
Basic
ClusterConfiguration for entry points. |
EntrypointClusterConfigurationParserFactory |
Parser factory for
EntrypointClusterConfiguration . |
JobClusterEntrypoint | Deprecated
Per-job mode has been deprecated in Flink 1.15 and will be removed in the future.
|
SessionClusterEntrypoint |
Base class for session cluster entry points.
|
StandaloneSessionClusterEntrypoint |
Entry point for the standalone session cluster.
|
WorkingDirectory |
Class that manages a working directory for a process/instance.
|
Enum | Description |
---|---|
ClusterEntrypoint.ExecutionMode |
Execution mode of the
MiniDispatcher . |
ClusterEntrypoint.ShutdownBehaviour |
Shutdown behaviour of a
ClusterEntrypoint . |
Exception | Description |
---|---|
ClusterEntrypointException |
Exceptions thrown by the
ClusterEntrypoint . |
FlinkParseException |
Exception which indicates that the parsing of command line arguments failed.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.