public class FlinkKubeClientFactory extends Object
FlinkKubeClientFactory
for creating the FlinkKubeClient
.Constructor and Description |
---|
FlinkKubeClientFactory() |
Modifier and Type | Method and Description |
---|---|
FlinkKubeClient |
fromConfiguration(Configuration flinkConfig,
String useCase)
Create a Flink Kubernetes client with the given configuration.
|
static FlinkKubeClientFactory |
getInstance() |
public static FlinkKubeClientFactory getInstance()
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.