Interface | Description |
---|---|
NewClusterClient |
Interface for the new cluster client.
|
Class | Description |
---|---|
ClusterClient<T> |
Encapsulates the functionality necessary to submit a program to a remote cluster.
|
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.
|
MiniClusterClient |
Client to interact with a
MiniCluster . |
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.
|
PackagedProgramUtils |
Utility class for
PackagedProgram related operations. |
PreviewPlanEnvironment |
Environment to extract the pre-optimized plan.
|
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 | 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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.