| Package | Description |
|---|---|
| org.apache.flink.metrics | |
| org.apache.flink.metrics.groups | |
| org.apache.flink.metrics.reporter |
| Modifier and Type | Method and Description |
|---|---|
default MetricGroup |
MetricGroup.addGroup(int name)
Creates a new MetricGroup and adds it to this groups sub-groups.
|
MetricGroup |
MetricGroup.addGroup(String name)
Creates a new MetricGroup and adds it to this groups sub-groups.
|
MetricGroup |
MetricGroup.addGroup(String key,
String value)
Creates a new key-value MetricGroup pair.
|
MetricGroup |
LogicalScopeProvider.getWrappedMetricGroup()
Returns the underlying metric group.
|
| Modifier and Type | Method and Description |
|---|---|
static LogicalScopeProvider |
LogicalScopeProvider.castFrom(MetricGroup metricGroup)
Casts the given metric group to a
LogicalScopeProvider, if it implements the
interface. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CacheMetricGroup
Pre-defined metrics for cache.
|
interface |
OperatorCoordinatorMetricGroup
Special
MetricGroup representing an Operator coordinator. |
interface |
OperatorIOMetricGroup
Metric group that contains shareable pre-defined IO-related metrics for operators.
|
interface |
OperatorMetricGroup
Special
MetricGroup representing an Operator. |
interface |
SinkWriterMetricGroup
Pre-defined metrics for sinks.
|
interface |
SourceReaderMetricGroup
Pre-defined metrics for
SourceReader. |
interface |
SplitEnumeratorMetricGroup
Pre-defined metrics for
SplitEnumerator. |
| Modifier and Type | Class and Description |
|---|---|
class |
UnregisteredMetricsGroup
A special
MetricGroup that does not register any metrics at the metrics registry and any
reporters. |
| Modifier and Type | Method and Description |
|---|---|
MetricGroup |
UnregisteredMetricsGroup.addGroup(String name) |
MetricGroup |
UnregisteredMetricsGroup.addGroup(String key,
String value) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
MetricReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a new
Metric was added. |
void |
AbstractReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
MetricReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a
Metric was removed. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.