Class and Description |
---|
ClusterClient
Encapsulates the functionality necessary to submit a program to a remote cluster.
|
PackagedProgram
This class encapsulates represents a program, packaged in a jar file.
|
ProgramInvocationException
Exception used to indicate that there is an error during the invocation of a Flink program.
|
Class and Description |
---|
PackagedProgram
This class encapsulates represents a program, packaged in a jar file.
|
ProgramInvocationException
Exception used to indicate that there is an error during the invocation of a Flink program.
|
Class and Description |
---|
ClusterClientProvider
Factory for
ClusterClients . |
Class and Description |
---|
ClusterClient
Encapsulates the functionality necessary to submit a program to a remote cluster.
|
ContextEnvironmentFactory
The factory that instantiates the environment to be used when running jobs that are
submitted through a pre-configured client connection.
|
MiniClusterClient.MiniClusterId
The type of the Cluster ID for the local
MiniCluster . |
PackagedProgram
This class encapsulates represents a program, packaged in a jar file.
|
PackagedProgram.Builder
A Builder For
PackagedProgram . |
PerJobMiniClusterFactory
Starts a
MiniCluster for every submitted job. |
ProgramInvocationException
Exception used to indicate that there is an error during the invocation of a Flink program.
|
Class and Description |
---|
ClusterClient
Encapsulates the functionality necessary to submit a program to a remote cluster.
|
Class and Description |
---|
ProgramParametrizationException
Exception used to indicate that there is an error in the parametrization of a Flink program.
|
Class and Description |
---|
ProgramParametrizationException
Exception used to indicate that there is an error in the parametrization of a Flink program.
|
Class and Description |
---|
ClusterClientProvider
Factory for
ClusterClients . |
Class and Description |
---|
ClusterClient
Encapsulates the functionality necessary to submit a program to a remote cluster.
|
Class and Description |
---|
ClusterClientProvider
Factory for
ClusterClients . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.