Class Fabric8FlinkStandaloneKubeClient

    • 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

      All Methods Static Methods Instance Methods Concrete Methods 
      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

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