Interface | Description |
---|---|
ClusterClientFactory<ClusterID> |
A factory containing all the necessary information for creating clients to Flink clusters.
|
ClusterClientServiceLoader |
An interface used to discover the appropriate
cluster client factory
based on the provided Configuration . |
ClusterDescriptor<T> |
A descriptor to deploy a cluster (e.g.
|
Class | Description |
---|---|
AbstractContainerizedClusterClientFactory<ClusterID> |
An abstract
ClusterClientFactory containing some common implementations for different
containerized deployment clusters. |
ClusterClientJobClientAdapter<ClusterID> |
An implementation of the
JobClient interface that uses a ClusterClient
underneath.. |
ClusterSpecification |
Description of the cluster to start by the
ClusterDescriptor . |
ClusterSpecification.ClusterSpecificationBuilder |
Builder for the
ClusterSpecification instance. |
DefaultClusterClientServiceLoader |
A service provider for
cluster client factories . |
StandaloneClientFactory |
A
ClusterClientFactory for a standalone cluster, i.e. |
StandaloneClusterDescriptor |
A deployment descriptor for an existing cluster.
|
StandaloneClusterId |
Identifier for standalone clusters.
|
Exception | Description |
---|---|
ClusterDeploymentException |
Class which indicates a problem when deploying a Flink cluster.
|
ClusterRetrieveException |
Exception which indicates that a cluster could not be retrieved.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.