Class FlinkResourceContextFactory
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
-
public class FlinkResourceContextFactory extends java.lang.Object
Factory for creating theFlinkResourceContext
.
-
-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <CR extends AbstractFlinkResource<?,?>>
voidcleanup(CR flinkApp)
protected FlinkService
getFlinkService(FlinkResourceContext<?> ctx)
<CR extends AbstractFlinkResource<?,?>>
FlinkResourceContext<CR>getResourceContext(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
-
-
-
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 AbstractFlinkResource<?,?>> FlinkResourceContext<CR> getResourceContext(CR resource, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
-
getFlinkService
@VisibleForTesting protected FlinkService getFlinkService(FlinkResourceContext<?> ctx)
-
cleanup
public <CR extends AbstractFlinkResource<?,?>> void cleanup(CR flinkApp)
-
-