Class KubernetesOperatorMetricGroup
- java.lang.Object
-
- org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<?>>
-
- org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
-
- All Implemented Interfaces:
org.apache.flink.metrics.MetricGroup
public class KubernetesOperatorMetricGroup extends org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<?>>
Base metric group for Flink Operator System metrics.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static KubernetesOperatorMetricGroup
create(org.apache.flink.runtime.metrics.MetricRegistry metricRegistry, org.apache.flink.configuration.Configuration configuration, java.lang.String namespace, java.lang.String name, java.lang.String hostname)
protected org.apache.flink.runtime.metrics.dump.QueryScopeInfo
createQueryServiceMetricInfo(org.apache.flink.metrics.CharacterFilter filter)
KubernetesResourceNamespaceMetricGroup
createResourceNamespaceGroup(org.apache.flink.configuration.Configuration config, java.lang.Class<? extends AbstractFlinkResource> resourceClass, java.lang.String resourceNs)
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, close, counter, counter, createChildGroup, createLogicalScope, gauge, getAllVariables, getAllVariables, getLogicalScope, getLogicalScope, getMetricIdentifier, getMetricIdentifier, getMetricIdentifier, getQueryServiceMetricInfo, getScopeComponents, histogram, isClosed, meter
-
-
-
-
Method Detail
-
createResourceNamespaceGroup
public KubernetesResourceNamespaceMetricGroup createResourceNamespaceGroup(org.apache.flink.configuration.Configuration config, java.lang.Class<? extends AbstractFlinkResource> resourceClass, java.lang.String resourceNs)
-
create
public static KubernetesOperatorMetricGroup create(org.apache.flink.runtime.metrics.MetricRegistry metricRegistry, org.apache.flink.configuration.Configuration configuration, java.lang.String namespace, java.lang.String name, java.lang.String hostname)
-
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<org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<?>>
-
getGroupName
protected final java.lang.String getGroupName(org.apache.flink.metrics.CharacterFilter filter)
- Specified by:
getGroupName
in classorg.apache.flink.runtime.metrics.groups.AbstractMetricGroup<org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<?>>
-
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<org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<?>>
-
-