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

Interface FlinkStandaloneKubeClient

  • All Superinterfaces:
    java.lang.AutoCloseable, org.apache.flink.kubernetes.kubeclient.FlinkKubeClient
    All Known Implementing Classes:
    Fabric8FlinkStandaloneKubeClient
    public interface FlinkStandaloneKubeClient
extends org.apache.flink.kubernetes.kubeclient.FlinkKubeClient
    Extension of the FlinkKubeClient that is used for Flink standalone deployments.

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

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void createTaskManagerDeployment​(io.fabric8.kubernetes.api.model.apps.Deployment tmDeployment)  

      • Methods inherited from interface org.apache.flink.kubernetes.kubeclient.FlinkKubeClient

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

    • Method Detail

      • createTaskManagerDeployment

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