Package | Description |
---|---|
org.apache.paimon.flink.metrics | |
org.apache.paimon.metrics | |
org.apache.paimon.operation.metrics |
Modifier and Type | Class and Description |
---|---|
class |
FlinkMetricGroup
MetricGroup which wraps a Flink's MetricGroup and
register all metrics into Flink's metric system. |
Modifier and Type | Method and Description |
---|---|
protected MetricGroup |
FlinkMetricRegistry.createMetricGroup(String groupName,
Map<String,String> variables) |
Modifier and Type | Class and Description |
---|---|
class |
MetricGroupImpl
Default implementation of
MetricGroup . |
Modifier and Type | Method and Description |
---|---|
protected MetricGroup |
MetricRegistryImpl.createMetricGroup(String groupName,
Map<String,String> variables) |
protected abstract MetricGroup |
MetricRegistry.createMetricGroup(String groupName,
Map<String,String> variables) |
MetricGroup |
MetricRegistry.tableMetricGroup(String groupName,
String tableName) |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
CompactionMetrics.getMetricGroup() |
MetricGroup |
CommitMetrics.getMetricGroup() |
MetricGroup |
ScanMetrics.getMetricGroup() |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.