org.apache.flink.kubernetes.kubeclient

Interface KubeClientFactory

All Known Implementing Classes:

DefaultKubeClientFactory

public interface KubeClientFactory

Factory to create FlinkKubeClient.

Method Summary

Modifier and Type	Method and Description
FlinkKubeClient	fromConfiguration(Configuration configuration) Get the kubernetes client with the given configuration.
FlinkKubeClient	fromConfiguration(Configuration configuration, Executor ioExecutor) Get the kubernetes client with the given configuration and io executor.

Method Detail

fromConfiguration

FlinkKubeClient fromConfiguration(Configuration configuration)

Get the kubernetes client with the given configuration.

Parameters:

configuration - flink configuration

Returns:

Return the kubernetes client with the specified configuration.

fromConfiguration

FlinkKubeClient fromConfiguration(Configuration configuration,
                                  Executor ioExecutor)

Get the kubernetes client with the given configuration and io executor.

Parameters:

configuration - flink configuration

ioExecutor - IO executor

Returns:

Return the kubernetes client with the specified flink configuration and IO executor.