Package org.apache.flink.kubernetes.operator.service

Class FlinkServiceFactory

java.lang.Object

org.apache.flink.kubernetes.operator.service.FlinkServiceFactory

public class FlinkServiceFactory
extends java.lang.Object

The factory to create the FlinkService based on the FlinkDeployment mode.

Constructor Summary

Constructors

Constructor	Description
FlinkServiceFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager)

Method Summary

Modifier and Type	Method	Description
FlinkService	getOrCreate(FlinkDeployment deployment)
FlinkService	getOrCreate(KubernetesDeploymentMode deploymentMode)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkServiceFactory

public FlinkServiceFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                           FlinkConfigManager configManager)

Method Detail

getOrCreate

public FlinkService getOrCreate(KubernetesDeploymentMode deploymentMode)

getOrCreate

public FlinkService getOrCreate(FlinkDeployment deployment)