Class FlinkKubeClientFactory

    • Constructor Detail

      • FlinkKubeClientFactory

        public FlinkKubeClientFactory()
    • Method Detail

      • createFabric8ioKubernetesClient

        @VisibleForTesting
        public io.fabric8.kubernetes.client.NamespacedKubernetesClient createFabric8ioKubernetesClient​(Configuration flinkConfig)
      • fromConfiguration

        public FlinkKubeClient fromConfiguration​(Configuration flinkConfig,
                                                 String useCase)
        Create a Flink Kubernetes client with the given configuration.
        Parameters:
        flinkConfig - Flink configuration
        useCase - Flink Kubernetes client use case (e.g. client, resourcemanager, kubernetes-ha-services)
        Returns:
        Return the Flink Kubernetes client with the specified configuration and dedicated IO executor.