Class KubernetesResourceNamespaceMetricGroup
- java.lang.Object
-
- org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesOperatorMetricGroup>
-
- org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
-
- All Implemented Interfaces:
org.apache.flink.metrics.MetricGroup
public class KubernetesResourceNamespaceMetricGroup extends org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesOperatorMetricGroup>
Base metric group for Flink Operator Resource namespace level metrics.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
KubernetesResourceNamespaceMetricGroup(org.apache.flink.runtime.metrics.MetricRegistry registry, KubernetesOperatorMetricGroup parent, java.lang.String[] scope, java.lang.String resourceNs, java.lang.String resourceType)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.flink.runtime.metrics.dump.QueryScopeInfo
createQueryServiceMetricInfo(org.apache.flink.metrics.CharacterFilter filter)
KubernetesResourceMetricGroup
createResourceGroup(org.apache.flink.configuration.Configuration config, java.lang.String resourceName)
protected java.lang.String
getGroupName(org.apache.flink.metrics.CharacterFilter filter)
protected void
putVariables(java.util.Map<java.lang.String,java.lang.String> variables)
-
Methods inherited from class org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addGroup, addGroup, addMetric, addSpan, close, counter, counter, createChildGroup, createLogicalScope, gauge, getAllVariables, getAllVariables, getLogicalScope, getLogicalScope, getMetricIdentifier, getMetricIdentifier, getMetricIdentifier, getQueryServiceMetricInfo, getScopeComponents, histogram, isClosed, meter
-
-
-
-
Constructor Detail
-
KubernetesResourceNamespaceMetricGroup
protected KubernetesResourceNamespaceMetricGroup(org.apache.flink.runtime.metrics.MetricRegistry registry, KubernetesOperatorMetricGroup parent, java.lang.String[] scope, java.lang.String resourceNs, java.lang.String resourceType)
-
-
Method Detail
-
createResourceGroup
public KubernetesResourceMetricGroup createResourceGroup(org.apache.flink.configuration.Configuration config, java.lang.String resourceName)
-
putVariables
protected final void putVariables(java.util.Map<java.lang.String,java.lang.String> variables)
- Overrides:
putVariables
in classorg.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesOperatorMetricGroup>
-
getGroupName
protected final java.lang.String getGroupName(org.apache.flink.metrics.CharacterFilter filter)
- Specified by:
getGroupName
in classorg.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesOperatorMetricGroup>
-
createQueryServiceMetricInfo
protected final org.apache.flink.runtime.metrics.dump.QueryScopeInfo createQueryServiceMetricInfo(org.apache.flink.metrics.CharacterFilter filter)
- Specified by:
createQueryServiceMetricInfo
in classorg.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesOperatorMetricGroup>
-
-