| Modifier and Type | Class and Description |
|---|---|
class |
FlinkMetricRegistry
MetricRegistry to create FlinkMetricGroup. |
| Modifier and Type | Method and Description |
|---|---|
FileStoreWrite<T> |
AbstractFileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry) |
FileStoreWrite<T> |
MemoryFileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry) |
FileStoreWrite<T> |
FileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry)
With metrics to measure compaction.
|
| Constructor and Description |
|---|
CommitMetrics(MetricRegistry registry,
String tableName) |
CompactionMetrics(MetricRegistry registry,
String tableName) |
ScanMetrics(MetricRegistry registry,
String tableName) |
WriterBufferMetric(java.util.function.Supplier<MemoryPoolFactory> memoryPoolFactorySupplier,
MetricRegistry metricRegistry,
String tableName) |
| Modifier and Type | Method and Description |
|---|---|
TableWriteImpl<T> |
TableWriteImpl.withMetricRegistry(MetricRegistry metricRegistry) |
TableWrite |
TableWrite.withMetricRegistry(MetricRegistry registry)
With metrics to measure compaction.
|
InnerTableCommit |
InnerTableCommit.withMetricRegistry(MetricRegistry registry) |
InnerTableCommit |
TableCommitImpl.withMetricRegistry(MetricRegistry registry) |
| Modifier and Type | Method and Description |
|---|---|
default InnerTableScan |
InnerTableScan.withMetricsRegistry(MetricRegistry metricRegistry) |
| Modifier and Type | Method and Description |
|---|---|
SnapshotReader |
SnapshotReaderImpl.withMetricRegistry(MetricRegistry registry) |
SnapshotReader |
SnapshotReader.withMetricRegistry(MetricRegistry registry) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.