@Internal public class KubernetesClusterClientFactory extends AbstractContainerizedClusterClientFactory<String>
ClusterClientFactory
for a Kubernetes cluster.Constructor and Description |
---|
KubernetesClusterClientFactory() |
Modifier and Type | Method and Description |
---|---|
KubernetesClusterDescriptor |
createClusterDescriptor(Configuration configuration)
Create a
ClusterDescriptor from the given configuration. |
String |
getClusterId(Configuration configuration)
Returns the cluster id if a cluster id is specified in the provided configuration, otherwise it returns
null . |
boolean |
isCompatibleWith(Configuration configuration)
Returns
true if the current ClusterClientFactory is compatible with the provided configuration,
false otherwise. |
getClusterSpecification
public boolean isCompatibleWith(Configuration configuration)
ClusterClientFactory
true
if the current ClusterClientFactory
is compatible with the provided configuration,
false
otherwise.public KubernetesClusterDescriptor createClusterDescriptor(Configuration configuration)
ClusterClientFactory
ClusterDescriptor
from the given configuration.configuration
- containing the configuration options relevant for the ClusterDescriptor
ClusterDescriptor
.@Nullable public String getClusterId(Configuration configuration)
ClusterClientFactory
null
.
A cluster id identifies a running cluster, e.g. the Yarn application id for a Flink cluster running on Yarn.
configuration
- containing the configuration options relevant for the cluster id retrievalCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.