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(FlinkConfigManager configManager, KubernetesOperatorMetricGroup operatorMetricGroup, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> void	cleanup(CR flinkApp)
protected FlinkService	getFlinkService(FlinkResourceContext<?> ctx)
<CR extends org.apache.flink.kubernetes.operator.api.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(FlinkConfigManager configManager,
                                   KubernetesOperatorMetricGroup operatorMetricGroup,
                                   EventRecorder eventRecorder)

Method Detail

getResourceContext

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

getFlinkService

@VisibleForTesting
protected FlinkService getFlinkService(FlinkResourceContext<?> ctx)

cleanup

public <CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> void cleanup(CR flinkApp)