org.apache.flink.client.deployment

Class AbstractContainerizedClusterClientFactory<ClusterID>

java.lang.Object

org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory<ClusterID>

All Implemented Interfaces:

ClusterClientFactory<ClusterID>

Direct Known Subclasses:

KubernetesClusterClientFactory, YarnClusterClientFactory

@Internal
public abstract class AbstractContainerizedClusterClientFactory<ClusterID>
extends Object
implements ClusterClientFactory<ClusterID>

An abstract ClusterClientFactory containing some common implementations for different containerized deployment clusters.

Constructor Summary

Constructors

Constructor and Description
AbstractContainerizedClusterClientFactory()

Method Summary

Modifier and Type	Method and Description
ClusterSpecification	getClusterSpecification(Configuration configuration) Returns the ClusterSpecification specified by the configuration and the command line options.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.client.deployment.ClusterClientFactory

createClusterDescriptor, getApplicationTargetName, getClusterId, isCompatibleWith

Constructor Detail

AbstractContainerizedClusterClientFactory

public AbstractContainerizedClusterClientFactory()

Method Detail

getClusterSpecification

public ClusterSpecification getClusterSpecification(Configuration configuration)

Description copied from interface: ClusterClientFactory

Returns the ClusterSpecification specified by the configuration and the command line options. This specification can be used to deploy a new Flink cluster.

Specified by:

getClusterSpecification in interface ClusterClientFactory<ClusterID>

Parameters:

configuration - containing the configuration options relevant for the ClusterSpecification

Returns:

the corresponding ClusterSpecification for a new Flink cluster