org.apache.flink.kubernetes

Class KubernetesClusterDescriptor

java.lang.Object

org.apache.flink.kubernetes.KubernetesClusterDescriptor

All Implemented Interfaces:

AutoCloseable, ClusterDescriptor<String>

public class KubernetesClusterDescriptor
extends Object
implements ClusterDescriptor<String>

Kubernetes specific ClusterDescriptor implementation.

Constructor Summary

Constructors

Constructor and Description
KubernetesClusterDescriptor(Configuration flinkConfig, FlinkKubeClient client)

Method Summary

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

KubernetesClusterDescriptor

public KubernetesClusterDescriptor(Configuration flinkConfig,
                                   FlinkKubeClient client)

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<String>

retrieve

public ClusterClientProvider<String> retrieve(String clusterId)

Description copied from interface: ClusterDescriptor

Retrieves an existing Flink Cluster.

Specified by:

retrieve in interface ClusterDescriptor<String>

Parameters:

clusterId - The unique identifier of the running cluster

Returns:

Client for the cluster

deploySessionCluster

public ClusterClientProvider<String> deploySessionCluster(ClusterSpecification clusterSpecification)
                                                   throws ClusterDeploymentException

Description copied from interface: ClusterDescriptor

Triggers deployment of a cluster.

Specified by:

deploySessionCluster in interface ClusterDescriptor<String>

Parameters:

clusterSpecification - Cluster specification defining the cluster to deploy

Returns:

Client for the cluster

Throws:

ClusterDeploymentException - if the cluster could not be deployed

deployApplicationCluster

public ClusterClientProvider<String> deployApplicationCluster(ClusterSpecification clusterSpecification,
                                                              ApplicationConfiguration applicationConfiguration)
                                                       throws ClusterDeploymentException

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<String>

Parameters:

clusterSpecification - Cluster specification defining the cluster to deploy

applicationConfiguration - Application-specific configuration parameters

Returns:

Client for the cluster

Throws:

ClusterDeploymentException - if the cluster could not be deployed

deployJobCluster

public ClusterClientProvider<String> deployJobCluster(ClusterSpecification clusterSpecification,
                                                      JobGraph jobGraph,
                                                      boolean detached)
                                               throws ClusterDeploymentException

Description copied from interface: ClusterDescriptor

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

Specified by:

deployJobCluster in interface ClusterDescriptor<String>

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

Throws:

ClusterDeploymentException - if the cluster could not be deployed

killCluster

public void killCluster(String clusterId)
                 throws FlinkException

Description copied from interface: ClusterDescriptor

Terminates the cluster with the given cluster id.

Specified by:

killCluster in interface ClusterDescriptor<String>

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<String>