Class KubernetesResourceMetricGroup
- java.lang.Object
-
- org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesResourceNamespaceMetricGroup>
-
- org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
-
- All Implemented Interfaces:
org.apache.flink.metrics.MetricGroup
public class KubernetesResourceMetricGroup extends org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesResourceNamespaceMetricGroup>
Base metric group for Flink Operator Resource level metrics.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
KubernetesResourceMetricGroup(org.apache.flink.runtime.metrics.MetricRegistry registry, KubernetesResourceNamespaceMetricGroup parent, java.lang.String[] scope, java.lang.String resourceName)
-
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)
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
-
KubernetesResourceMetricGroup
protected KubernetesResourceMetricGroup(org.apache.flink.runtime.metrics.MetricRegistry registry, KubernetesResourceNamespaceMetricGroup parent, java.lang.String[] scope, java.lang.String resourceName)
-
-
Method Detail
-
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<KubernetesResourceNamespaceMetricGroup>
-
getGroupName
protected final java.lang.String getGroupName(org.apache.flink.metrics.CharacterFilter filter)
- Specified by:
getGroupName
in classorg.apache.flink.runtime.metrics.groups.AbstractMetricGroup<KubernetesResourceNamespaceMetricGroup>
-
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<KubernetesResourceNamespaceMetricGroup>
-
-