Package org.apache.flink.kubernetes.operator.service

Class FlinkServiceFactory

  • public class FlinkServiceFactory
extends java.lang.Object
    The factory to create the FlinkService based on the FlinkDeployment mode.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      FlinkService getOrCreate​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)  
      FlinkService getOrCreate​(org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode deploymentMode)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • FlinkServiceFactory

        public FlinkServiceFactory​(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                           FlinkConfigManager configManager)

    • Method Detail

      • getOrCreate

        public FlinkService getOrCreate​(org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode deploymentMode)

      • getOrCreate

        public FlinkService getOrCreate​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)