Class FlinkKubeClientFactory
- java.lang.Object
-
- org.apache.flink.kubernetes.kubeclient.FlinkKubeClientFactory
-
public class FlinkKubeClientFactory extends Object
AFlinkKubeClientFactory
for creating theFlinkKubeClient
.
-
-
Constructor Summary
Constructors Constructor Description FlinkKubeClientFactory()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description io.fabric8.kubernetes.client.NamespacedKubernetesClient
createFabric8ioKubernetesClient(Configuration flinkConfig)
FlinkKubeClient
fromConfiguration(Configuration flinkConfig, String useCase)
Create a Flink Kubernetes client with the given configuration.static FlinkKubeClientFactory
getInstance()
-
-
-
Method Detail
-
getInstance
public static FlinkKubeClientFactory getInstance()
-
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 configurationuseCase
- 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.
-
-