org.apache.flink.client.deployment

Class StandaloneClusterDescriptor

java.lang.Object

org.apache.flink.client.deployment.StandaloneClusterDescriptor

All Implemented Interfaces:

AutoCloseable, ClusterDescriptor<StandaloneClusterId>

public class StandaloneClusterDescriptor
extends Object
implements ClusterDescriptor<StandaloneClusterId>

A deployment descriptor for an existing cluster.

Constructor Summary

Constructors

Constructor and Description
StandaloneClusterDescriptor(Configuration config)

Method Summary

Modifier and Type	Method and Description
void	close()
ClusterClientProvider<StandaloneClusterId>	deployApplicationCluster(ClusterSpecification clusterSpecification, ApplicationConfiguration applicationConfiguration) Triggers deployment of an application cluster.
ClusterClientProvider<StandaloneClusterId>	deployJobCluster(ClusterSpecification clusterSpecification, JobGraph jobGraph, boolean detached) Deploys a per-job cluster with the given job on the cluster.
ClusterClientProvider<StandaloneClusterId>	deploySessionCluster(ClusterSpecification clusterSpecification) Triggers deployment of a cluster.
String	getClusterDescription() Returns a String containing details about the cluster (NodeManagers, available memory, ...).
void	killCluster(StandaloneClusterId clusterId) Terminates the cluster with the given cluster id.
ClusterClientProvider<StandaloneClusterId>	retrieve(StandaloneClusterId standaloneClusterId) Retrieves an existing Flink Cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

StandaloneClusterDescriptor

public StandaloneClusterDescriptor(Configuration config)

Method Detail

getClusterDescription

public String getClusterDescription()

Description copied from interface: ClusterDescriptor

Returns a String containing details about the cluster (NodeManagers, available memory, ...).

Specified by:

getClusterDescription in interface ClusterDescriptor<StandaloneClusterId>

retrieve

public ClusterClientProvider<StandaloneClusterId> retrieve(StandaloneClusterId standaloneClusterId)
                                                    throws ClusterRetrieveException

Description copied from interface: ClusterDescriptor

Retrieves an existing Flink Cluster.

Specified by:

retrieve in interface ClusterDescriptor<StandaloneClusterId>

Parameters:

standaloneClusterId - The unique identifier of the running cluster

Returns:

Client for the cluster

Throws:

ClusterRetrieveException - if the cluster client could not be retrieved

deploySessionCluster

public ClusterClientProvider<StandaloneClusterId> deploySessionCluster(ClusterSpecification clusterSpecification)

Description copied from interface: ClusterDescriptor

Triggers deployment of a cluster.

Specified by:

deploySessionCluster in interface ClusterDescriptor<StandaloneClusterId>

Parameters:

clusterSpecification - Cluster specification defining the cluster to deploy

Returns:

Client for the cluster

deployApplicationCluster

public ClusterClientProvider<StandaloneClusterId> deployApplicationCluster(ClusterSpecification clusterSpecification,
                                                                           ApplicationConfiguration applicationConfiguration)

Description copied from interface: ClusterDescriptor

Triggers deployment of an application cluster. This corresponds to a cluster dedicated to the execution of a predefined application. The cluster will be created on application submission and torn down upon application termination. In addition, the main() of the application's user code will be executed on the cluster, rather than the client.

Specified by:

deployApplicationCluster in interface ClusterDescriptor<StandaloneClusterId>

Parameters:

clusterSpecification - Cluster specification defining the cluster to deploy

applicationConfiguration - Application-specific configuration parameters

Returns:

Client for the cluster

deployJobCluster

public ClusterClientProvider<StandaloneClusterId> deployJobCluster(ClusterSpecification clusterSpecification,
                                                                   JobGraph jobGraph,
                                                                   boolean detached)

Description copied from interface: ClusterDescriptor

Deploys a per-job cluster with the given job on the cluster.

Specified by:

deployJobCluster in interface ClusterDescriptor<StandaloneClusterId>

Parameters:

clusterSpecification - Initial cluster specification with which the Flink cluster is launched

jobGraph - JobGraph with which the job cluster is started

detached - true if the cluster should be stopped after the job completion without serving the result, otherwise false

Returns:

Cluster client to talk to the Flink cluster

killCluster

public void killCluster(StandaloneClusterId clusterId)
                 throws FlinkException

Description copied from interface: ClusterDescriptor

Terminates the cluster with the given cluster id.

Specified by:

killCluster in interface ClusterDescriptor<StandaloneClusterId>

Parameters:

clusterId - identifying the cluster to shut down

Throws:

FlinkException - if the cluster could not be terminated

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ClusterDescriptor<StandaloneClusterId>