All Classes

Class	Description
AbstractContainerizedClusterClientFactory<ClusterID>	An abstract ClusterClientFactory containing some common implementations for different containerized deployment clusters.
AbstractCustomCommandLine	Base class for CustomCommandLine implementations which specify a JobManager address and a ZooKeeper namespace.
AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>	Deprecated.
AbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>>	An abstract PipelineExecutor used to execute pipelines on an existing (session) cluster.
ApplicationClusterDeployer	An entity responsible for submitting an application for execution in "Application Mode", i.e.
ApplicationClusterEntryPoint	Base class for cluster entry points targeting executing applications in "Application Mode".
ApplicationConfiguration	Application-specific configurations.
ApplicationDeployer	An interface to be used by the CliFrontend to submit user programs for execution.
ApplicationDispatcherBootstrap	A DispatcherBootstrap used for running the user's main() in "Application Mode" (see FLIP-85).
ApplicationDispatcherGatewayServiceFactory	A DispatcherGatewayServiceFactory used when executing a job in Application Mode, i.e.
ApplicationDispatcherLeaderProcessFactoryFactory	Factory for a DispatcherLeaderProcessFactoryFactory designed to be used when executing an application in Application Mode.
ApplicationExecutionException	A FlinkException thrown in case something during application execution went wrong.
ApplicationRunner	An interface to be implemented by the entities responsible for application submission for the different deployment environments.
ArtifactFetchManager	Class that manages the artifact loading process.
ArtifactFetchManager.Result	Artifact fetch result with all fetched artifact(s).
ArtifactFetchOptions	Artifact Fetch options.
ArtifactUtils	Artifact fetch related utils.
CancelOptions	Command line options for the CANCEL command.
CheckpointOptions	Command line options for the CHECKPOINT command.
CliArgsException	Special exception that is thrown when the command line parsing fails.
ClientOptions	Describes a client configuration parameter.
ClientUtils	Utility functions for Flink client.
CliFrontend	Implementation of a simple command line frontend for executing programs.
CliFrontendParser	A simple command line parser (based on Apache Commons CLI) that extracts command line options.
ClusterClient<T>	Encapsulates the functionality necessary to submit a program to a remote cluster.
ClusterClientFactory<ClusterID>	A factory containing all the necessary information for creating clients to Flink clusters.
ClusterClientJobClientAdapter<ClusterID>	An implementation of the JobClient interface that uses a ClusterClient underneath..
ClusterClientProvider<T>	Factory for ClusterClients.
ClusterClientServiceLoader	An interface used to discover the appropriate cluster client factory based on the provided Configuration.
ClusterDeploymentException	Class which indicates a problem when deploying a Flink cluster.
ClusterDescriptor<T>	A descriptor to deploy a cluster (e.g.
ClusterRetrieveException	Exception which indicates that a cluster could not be retrieved.
ClusterSpecification	Description of the cluster to start by the ClusterDescriptor.
ClusterSpecification.ClusterSpecificationBuilder	Builder for the ClusterSpecification instance.
CommandLineOptions	Base class for all options parsed from the command line.
ContextEnvironment	Execution Environment for remote execution with the Client.
CustomCommandLine	Custom command-line interface to load hooks for the command-line interface.
DefaultCLI	The default CLI which is used for interaction with standalone clusters.
DefaultClusterClientServiceLoader	A service provider for cluster client factories.
DefaultPackagedProgramRetriever	PackageProgramRetrieverImpl is the default implementation of PackagedProgramRetriever that can either retrieve a PackagedProgram from a specific jar, some provided user classpath or the system classpath.
DetachedApplicationRunner	An ApplicationRunner which runs the user specified application using the EmbeddedExecutor.
DynamicPropertiesUtil	Helper class for supporting dynamic property commandline options in CustomCommandLines.
EmbeddedExecutor	A base class for executors that invoke directly methods of the Dispatcher and do not go through the REST API.
EmbeddedExecutorFactory	An PipelineExecutorFactory for the EmbeddedExecutor.
EmbeddedExecutorServiceLoader	A PipelineExecutorServiceLoader that always returns an EmbeddedExecutorFactory.
EmbeddedJobClient	A JobClient with the ability to also submit jobs which uses directly the DispatcherGateway.
EmbeddedJobClientCreator	An interface to be implemented by JobClient suppliers.
EntryClassInformationProvider	EntryClassInformationProvider provides information about the entry class.
ExecutionConfigAccessor	Accessor that exposes config settings that are relevant for execution from an underlying Configuration.
ExponentialWaitStrategy	WaitStrategy with exponentially increasing sleep time.
FlinkPipelineTranslationUtil	Utility for transforming FlinkPipelines into a JobGraph.
FlinkPipelineTranslator	This can be used to turn a Pipeline into a JobGraph.
FromClasspathEntryClassInformationProvider	FromClasspathEntryClassInformationProvider assumes the passed job class being available on some classpath.
FromJarEntryClassInformationProvider	FromJarEntryClassInformationProvider is used for cases where the Jar archive is explicitly specified.
GenericCLI	A generic implementation of the CustomCommandLine that only expects the execution.target parameter to be explicitly specified and simply forwards the rest of the options specified with -D to the corresponding PipelineExecutor for further parsing.
JarManifestParser	Utility that parses JAR manifest attributes.
ListOptions	Command line options for the LIST command.
LocalExecutor	An PipelineExecutor for executing a Pipeline locally.
LocalExecutorFactory	An PipelineExecutorFactory for local executors.
MiniClusterClient	Client to interact with a MiniCluster.
MiniClusterClient.MiniClusterId	The type of the Cluster ID for the local MiniCluster.
MutatedConfigurationException	If DeploymentOptions.PROGRAM_CONFIG_ENABLED is disabled, configurations in the user jar will throw this exception.
OptimizerPlanEnvironment	An ExecutionEnvironment that never executes a job but only extracts the Pipeline.
PackagedProgram	This class encapsulates represents a program, packaged in a jar file.
PackagedProgram.Builder	A Builder For PackagedProgram.
PackagedProgramRetriever	Interface which allows to retrieve the PackagedProgram.
PackagedProgramUtils	Utility class for PackagedProgram related operations.
PerJobMiniClusterFactory	Starts a MiniCluster for every submitted job.
PipelineExecutorUtils	Utility class with method related to job execution.
PlanTranslator	FlinkPipelineTranslator for DataSet API Plans.
ProgramAbortException	A special exception used to abort programs when the caller is only interested in the program plan, rather than in the full execution.
ProgramInvocationException	Exception used to indicate that there is an error during the invocation of a Flink program.
ProgramMissingJobException	Exception used to indicate that no job was executed during the invocation of a Flink program.
ProgramOptions	Base class for command line options that refer to a JAR file program.
ProgramOptionsUtils	Utility class for ProgramOptions.
ProgramParametrizationException	Exception used to indicate that there is an error in the parametrization of a Flink program.
RemoteExecutor	The PipelineExecutor to be used when executing a job on an already running cluster.
RemoteExecutorFactory	An PipelineExecutorFactory for remote executors.
RestClusterClient<T>	A ClusterClient implementation that communicates via HTTP REST requests.
RestClusterClientConfiguration	A configuration object for RestClusterClients.
SavepointOptions	Command line options for the SAVEPOINT command.
StandaloneClientFactory	A ClusterClientFactory for a standalone cluster, i.e.
StandaloneClusterDescriptor	A deployment descriptor for an existing cluster.
StandaloneClusterId	Identifier for standalone clusters.
StreamContextEnvironment	Special StreamExecutionEnvironment that will be used in cases where the CLI client or testing utilities create a StreamExecutionEnvironment that should be used when StreamExecutionEnvironment.getExecutionEnvironment() is called.
StreamGraphTranslator	FlinkPipelineTranslator for DataStream API StreamGraphs.
StreamPlanEnvironment	A special StreamExecutionEnvironment that is used in the web frontend when generating a user-inspectable graph of a streaming job.
UnsuccessfulExecutionException	Exception that signals the failure of an application with a given ApplicationStatus.
UrlPrefixDecorator<R extends org.apache.flink.runtime.rest.messages.RequestBody,P extends org.apache.flink.runtime.rest.messages.ResponseBody,M extends org.apache.flink.runtime.rest.messages.MessageParameters>	This class decorates the URL of the original message headers by adding a prefix.
WaitStrategy	Operations that are polling for a result to arrive require a waiting time between consecutive polls.
WebSubmissionExecutorFactory	A PipelineExecutorFactory for an EmbeddedExecutor that returns a WebSubmissionJobClient.
WebSubmissionExecutorServiceLoader	A PipelineExecutorServiceLoader that always returns an WebSubmissionExecutorFactory.
WebSubmissionJobClient	A JobClient that only allows asking for the job id of the job it is attached to.