public class FlinkKubeClientFactory extends Object
FlinkKubeClientFactory
for creating the FlinkKubeClient
.Constructor and Description |
---|
FlinkKubeClientFactory() |
Modifier and Type | Method and 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() |
public static FlinkKubeClientFactory getInstance()
@VisibleForTesting public io.fabric8.kubernetes.client.NamespacedKubernetesClient createFabric8ioKubernetesClient(Configuration flinkConfig)
public FlinkKubeClient fromConfiguration(Configuration flinkConfig, String useCase)
flinkConfig
- Flink configurationuseCase
- Flink Kubernetes client use case (e.g. client, resourcemanager,
kubernetes-ha-services)Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.