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.

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Map<org.apache.flink.api.java.tuple.Tuple2<java.lang.Class<?>,io.javaoperatorsdk.operator.processing.event.ResourceID>,KubernetesResourceMetricGroup>	resourceMetricGroups

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
<CR extends AbstractFlinkResource<?,?>> void	cleanup(CR flinkApp)
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

Field Detail

resourceMetricGroups

protected final java.util.Map<org.apache.flink.api.java.tuple.Tuple2<java.lang.Class<?>,io.javaoperatorsdk.operator.processing.event.ResourceID>,KubernetesResourceMetricGroup> resourceMetricGroups

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)

cleanup

public <CR extends AbstractFlinkResource<?,?>> void cleanup(CR flinkApp)