Interface for the new cluster client.
Encapsulates the functionality necessary to submit a program to a remote cluster.
Utility class to lazily instantiate an
Execution Environment for remote execution with the Client.
The factory that instantiates the environment to be used when running jobs that are submitted through a pre-configured client connection.
Execution Environment for remote execution with the Client in detached mode.
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.
Client to interact with a
This class encapsulates represents a program, packaged in a jar file.
Utility class for
Environment to extract the pre-optimized plan.
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 used to indicate that there is an error during the invocation of a Flink program.
Exception used to indicate that no job was executed during the invocation of a Flink program.
Exception used to indicate that there is an error in the parametrization of a Flink program.
A special exception used to abort programs when the caller is only interested in the program plan, rather than in the full execution.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.