Package org.apache.flink.client.program

Class Summary

Class	Description
ClusterClient	Encapsulates the functionality necessary to submit a program to a remote cluster.
ClusterClient.LazyActorSystemLoader	Utility class to lazily instantiate an ActorSystem.
ContextEnvironment	Execution Environment for remote execution with the Client.
ContextEnvironmentFactory	The factory that instantiates the environment to be used when running jobs that are submitted through a pre-configured client connection.
DetachedEnvironment	Execution Environment for remote execution with the Client in detached mode.
DetachedEnvironment.DetachedJobExecutionResult	The JobExecutionResult returned by a DetachedEnvironment.
JobWithJars	A JobWithJars is a Flink dataflow plan, together with a bunch of JAR files that contain the classes of the functions and libraries necessary for the execution.
OptimizerPlanEnvironment	An ExecutionEnvironment that never executes a job but only creates the optimized plan.
PackagedProgram	This class encapsulates represents a program, packaged in a jar file.
PreviewPlanEnvironment	Environment to extract the pre-optimized plan.
StandaloneClusterClient	Cluster client for communication with an standalone (on-premise) cluster or an existing cluster that has been brought up independently of a specific job.

Exception Summary

Exception	Description
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.
ProgramParametrizationException	Exception used to indicate that there is an error in the parametrization of a Flink program.

Error Summary

Error	Description
OptimizerPlanEnvironment.ProgramAbortException	A special exception used to abort programs when the caller is only interested in the program plan, rather than in the full execution.