Package | Description |
---|---|
org.apache.flink.changelog.fs | |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.state.common |
Modifier and Type | Class and Description |
---|---|
class |
ChangelogStorageMetricGroup
Metrics related to the Changelog Storage used by the Changelog State Backend.
|
Modifier and Type | Class and Description |
---|---|
class |
FrontMetricGroup<P extends AbstractMetricGroup<?>>
Metric group which forwards all registration calls to a variable parent metric group that injects
a variable reporter index into calls to
MetricGroup.getMetricIdentifier(String) or MetricGroup.getMetricIdentifier(String, CharacterFilter) . |
class |
InternalCacheMetricGroup
A
CacheMetricGroup which register all cache related metrics under a subgroup of the
parent metric group. |
class |
InternalOperatorIOMetricGroup
Metric group that contains shareable pre-defined IO-related metrics.
|
class |
InternalSinkWriterMetricGroup
Special
MetricGroup representing an Operator. |
class |
InternalSourceReaderMetricGroup
Special
MetricGroup representing an Operator. |
class |
TaskIOMetricGroup
Metric group that contains shareable pre-defined IO-related metrics.
|
Modifier and Type | Class and Description |
---|---|
class |
ChangelogMaterializationMetricGroup
Metrics related to the materialization part of Changelog.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.