Package org.apache.flink.client.program
package org.apache.flink.client.program
-
ClassDescriptionEncapsulates the functionality necessary to submit a program to a remote cluster.Factory for
ClusterClients.PackageProgramRetrieverImplis the default implementation ofPackagedProgramRetrieverthat can either retrieve aPackagedProgramfrom a specific jar, some provided user classpath or the system classpath.Client to interact with aMiniCluster.The type of the Cluster ID for the localMiniCluster.IfDeploymentOptions.PROGRAM_CONFIG_ENABLEDis disabled, configurations in the user jar will throw this exception.This class encapsulates represents a program, packaged in a jar file.A Builder ForPackagedProgram.Interface which allows to retrieve thePackagedProgram.Utility class forPackagedProgramrelated operations.Starts aMiniClusterfor every submitted job.A special exception used to abort programs when the caller is only interested in the program plan, rather than in the full execution.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.SpecialStreamExecutionEnvironmentthat will be used in cases where the CLI client or testing utilities create aStreamExecutionEnvironmentthat should be used whenStreamExecutionEnvironment.getExecutionEnvironment()is called.A specialStreamExecutionEnvironmentthat is used in the web frontend when generating a user-inspectable graph of a streaming job.