Package org.apache.flink.kubernetes

Class KubernetesClusterDescriptor

java.lang.Object

org.apache.flink.kubernetes.KubernetesClusterDescriptor

All Implemented Interfaces:

AutoCloseable, org.apache.flink.client.deployment.ClusterDescriptor<String>

public class KubernetesClusterDescriptor
extends Object
implements org.apache.flink.client.deployment.ClusterDescriptor<String>

Kubernetes specific ClusterDescriptor implementation.

Constructor Summary

Constructors

Constructor	Description
KubernetesClusterDescriptor(org.apache.flink.configuration.Configuration flinkConfig, FlinkKubeClientFactory clientFactory)

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.flink.client.program.ClusterClientProvider<String>	deployApplicationCluster(org.apache.flink.client.deployment.ClusterSpecification clusterSpecification, org.apache.flink.client.deployment.application.ApplicationConfiguration applicationConfiguration)
org.apache.flink.client.program.ClusterClientProvider<String>	deployJobCluster(org.apache.flink.client.deployment.ClusterSpecification clusterSpecification, org.apache.flink.runtime.jobgraph.JobGraph jobGraph, boolean detached)
org.apache.flink.client.program.ClusterClientProvider<String>	deploySessionCluster(org.apache.flink.client.deployment.ClusterSpecification clusterSpecification)
String	getClusterDescription()
void	killCluster(String clusterId)
org.apache.flink.client.program.ClusterClientProvider<String>	retrieve(String clusterId)

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesClusterDescriptor

public KubernetesClusterDescriptor(org.apache.flink.configuration.Configuration flinkConfig,
                                   FlinkKubeClientFactory clientFactory)

Method Detail

getClusterDescription

public String getClusterDescription()

Specified by:

getClusterDescription in interface org.apache.flink.client.deployment.ClusterDescriptor<String>

retrieve

public org.apache.flink.client.program.ClusterClientProvider<String> retrieve(String clusterId)

Specified by:

retrieve in interface org.apache.flink.client.deployment.ClusterDescriptor<String>

deploySessionCluster

public org.apache.flink.client.program.ClusterClientProvider<String> deploySessionCluster(org.apache.flink.client.deployment.ClusterSpecification clusterSpecification)
                                                                                   throws org.apache.flink.client.deployment.ClusterDeploymentException

Specified by:

deploySessionCluster in interface org.apache.flink.client.deployment.ClusterDescriptor<String>

Throws:

org.apache.flink.client.deployment.ClusterDeploymentException

deployApplicationCluster

public org.apache.flink.client.program.ClusterClientProvider<String> deployApplicationCluster(org.apache.flink.client.deployment.ClusterSpecification clusterSpecification,
                                                                                              org.apache.flink.client.deployment.application.ApplicationConfiguration applicationConfiguration)
                                                                                       throws org.apache.flink.client.deployment.ClusterDeploymentException

Specified by:

deployApplicationCluster in interface org.apache.flink.client.deployment.ClusterDescriptor<String>

Throws:

org.apache.flink.client.deployment.ClusterDeploymentException

deployJobCluster

public org.apache.flink.client.program.ClusterClientProvider<String> deployJobCluster(org.apache.flink.client.deployment.ClusterSpecification clusterSpecification,
                                                                                      org.apache.flink.runtime.jobgraph.JobGraph jobGraph,
                                                                                      boolean detached)
                                                                               throws org.apache.flink.client.deployment.ClusterDeploymentException

Specified by:

deployJobCluster in interface org.apache.flink.client.deployment.ClusterDescriptor<String>

Throws:

org.apache.flink.client.deployment.ClusterDeploymentException

killCluster

public void killCluster(String clusterId)
                 throws org.apache.flink.util.FlinkException

Specified by:

killCluster in interface org.apache.flink.client.deployment.ClusterDescriptor<String>

Throws:

org.apache.flink.util.FlinkException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.flink.client.deployment.ClusterDescriptor<String>