@Internal public abstract class AbstractContainerizedClusterClientFactory<ClusterID> extends Object implements ClusterClientFactory<ClusterID>
ClusterClientFactory
containing some common implementations for different containerized deployment clusters.Constructor and Description |
---|
AbstractContainerizedClusterClientFactory() |
Modifier and Type | Method and Description |
---|---|
ClusterSpecification |
getClusterSpecification(Configuration configuration)
Returns the
ClusterSpecification specified by the configuration and the command
line options. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createClusterDescriptor, getClusterId, isCompatibleWith
public AbstractContainerizedClusterClientFactory()
public 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<ClusterID>
configuration
- containing the configuration options relevant for the ClusterSpecification
ClusterSpecification
for a new Flink clusterCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.