Package org.apache.flink.kubernetes.operator.kubeclient

Class Fabric8FlinkStandaloneKubeClient

java.lang.Object

org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient

org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.flink.kubernetes.kubeclient.FlinkKubeClient, FlinkStandaloneKubeClient

public class Fabric8FlinkStandaloneKubeClient
extends org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient
implements FlinkStandaloneKubeClient

The Implementation of FlinkStandaloneKubeClient.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.kubernetes.kubeclient.FlinkKubeClient

org.apache.flink.kubernetes.kubeclient.FlinkKubeClient.WatchCallbackHandler<T extends java.lang.Object>

Constructor Summary

Constructors

Constructor	Description
Fabric8FlinkStandaloneKubeClient(org.apache.flink.configuration.Configuration flinkConfig, io.fabric8.kubernetes.client.NamespacedKubernetesClient client, java.util.concurrent.ExecutorService executorService)

Method Summary

Modifier and Type	Method	Description
static Fabric8FlinkStandaloneKubeClient	create(org.apache.flink.configuration.Configuration conf, java.util.concurrent.ExecutorService executorService)
void	createTaskManagerDeployment(io.fabric8.kubernetes.api.model.apps.Deployment tmDeployment)
void	stopAndCleanupCluster(java.lang.String clusterId)

Methods inherited from class org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient

checkAndUpdateConfigMap, close, createConfigMap, createConfigMapSharedWatcher, createJobManagerComponent, createLeaderElector, createTaskManagerPod, deleteConfigMap, deleteConfigMapsByLabels, getConfigMap, getPodsWithLabels, getRestEndpoint, getService, loadPodFromTemplateFile, stopPod, updateServiceTargetPort, watchPodsAndDoCallback

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.kubernetes.kubeclient.FlinkKubeClient

checkAndUpdateConfigMap, close, createConfigMap, createConfigMapSharedWatcher, createJobManagerComponent, createLeaderElector, createTaskManagerPod, deleteConfigMap, deleteConfigMapsByLabels, getConfigMap, getPodsWithLabels, getRestEndpoint, getService, loadPodFromTemplateFile, stopPod, updateServiceTargetPort, watchPodsAndDoCallback

Constructor Detail

Fabric8FlinkStandaloneKubeClient

@VisibleForTesting
public Fabric8FlinkStandaloneKubeClient(org.apache.flink.configuration.Configuration flinkConfig,
                                        io.fabric8.kubernetes.client.NamespacedKubernetesClient client,
                                        java.util.concurrent.ExecutorService executorService)

Method Detail

createTaskManagerDeployment

public void createTaskManagerDeployment(io.fabric8.kubernetes.api.model.apps.Deployment tmDeployment)

Specified by:

createTaskManagerDeployment in interface FlinkStandaloneKubeClient

stopAndCleanupCluster

public void stopAndCleanupCluster(java.lang.String clusterId)

Specified by:

stopAndCleanupCluster in interface org.apache.flink.kubernetes.kubeclient.FlinkKubeClient

Overrides:

stopAndCleanupCluster in class org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient

create

public static Fabric8FlinkStandaloneKubeClient create(org.apache.flink.configuration.Configuration conf,
                                                      java.util.concurrent.ExecutorService executorService)