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​(org.apache.flink.kubernetes.shaded.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, getConfigMap, getPodsWithLabels, getRestEndpoint, getService, loadPodFromTemplateFile, stopAndCleanupCluster, stopPod, updateServiceTargetPort, watchPodsAndDoCallback
    • Method Detail

      • createTaskManagerDeployment

        void createTaskManagerDeployment​(org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.api.model.apps.Deployment tmDeployment)