@Internal public class StandaloneClientFactory extends Object implements ClusterClientFactory<StandaloneClusterId>
ClusterClientFactory
for a standalone cluster, i.e. Flink on bare-metal.Constructor and Description |
---|
StandaloneClientFactory() |
Modifier and Type | Method and Description |
---|---|
StandaloneClusterDescriptor |
createClusterDescriptor(Configuration configuration)
Create a
ClusterDescriptor from the given configuration. |
StandaloneClusterId |
getClusterId(Configuration configuration)
Returns the cluster id if a cluster id is specified in the provided configuration, otherwise
it returns
null . |
ClusterSpecification |
getClusterSpecification(Configuration configuration)
Returns the
ClusterSpecification specified by the configuration and the command line
options. |
boolean |
isCompatibleWith(Configuration configuration)
Returns
true if the current ClusterClientFactory is compatible with the
provided configuration, false otherwise. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getApplicationTargetName
public boolean isCompatibleWith(Configuration configuration)
ClusterClientFactory
true
if the current ClusterClientFactory
is compatible with the
provided configuration, false
otherwise.isCompatibleWith
in interface ClusterClientFactory<StandaloneClusterId>
public StandaloneClusterDescriptor createClusterDescriptor(Configuration configuration)
ClusterClientFactory
ClusterDescriptor
from the given configuration.createClusterDescriptor
in interface ClusterClientFactory<StandaloneClusterId>
configuration
- containing the configuration options relevant for the ClusterDescriptor
ClusterDescriptor
.@Nullable public StandaloneClusterId 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.
getClusterId
in interface ClusterClientFactory<StandaloneClusterId>
configuration
- containing the configuration options relevant for the cluster id
retrievalpublic ClusterSpecification getClusterSpecification(Configuration configuration)
ClusterClientFactory
ClusterSpecification
specified by the configuration and the command line
options. This specification can be used to deploy a new Flink cluster.getClusterSpecification
in interface ClusterClientFactory<StandaloneClusterId>
configuration
- containing the configuration options relevant for the ClusterSpecification
ClusterSpecification
for a new Flink clusterCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.