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

Class FlinkResourceContextFactory

java.lang.Object

org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

public class FlinkResourceContextFactory
extends java.lang.Object

Factory for creating the FlinkResourceContext.

Constructor Summary

Constructors

Constructor	Description
FlinkResourceContextFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager, KubernetesOperatorMetricGroup operatorMetricGroup)

Method Summary

Modifier and Type	Method	Description
protected FlinkService	getOrCreateFlinkService(FlinkDeployment deployment)
<CR extends AbstractFlinkResource<?,?>> FlinkResourceContext<CR>	getResourceContext(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkResourceContextFactory

public FlinkResourceContextFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                                   FlinkConfigManager configManager,
                                   KubernetesOperatorMetricGroup operatorMetricGroup)

Method Detail

getResourceContext

public <CR extends AbstractFlinkResource<?,?>> FlinkResourceContext<CR> getResourceContext(CR resource,
                                                                                                 io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)

getOrCreateFlinkService

@VisibleForTesting
protected FlinkService getOrCreateFlinkService(FlinkDeployment deployment)