| Modifier and Type | Class and Description |
|---|---|
class |
FlinkMetricRegistry
MetricRegistry to create FlinkMetricGroup. |
| Modifier and Type | Class and Description |
|---|---|
class |
MetricRegistryImpl
Default implementation of
MetricRegistry. |
| Modifier and Type | Method and Description |
|---|---|
FileStoreWrite<T> |
MemoryFileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry) |
FileStoreWrite<T> |
FileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry)
With metrics to measure compaction.
|
FileStoreWrite<T> |
AbstractFileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry) |
| 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 |
|---|---|
TableWrite |
TableWrite.withMetricRegistry(MetricRegistry registry)
With metrics to measure compaction.
|
TableWriteImpl<T> |
TableWriteImpl.withMetricRegistry(MetricRegistry metricRegistry) |
InnerTableCommit |
TableCommitImpl.withMetricRegistry(MetricRegistry registry) |
InnerTableCommit |
InnerTableCommit.withMetricRegistry(MetricRegistry registry) |
| Modifier and Type | Method and Description |
|---|---|
AbstractDataTableScan |
AbstractDataTableScan.withMetricsRegistry(MetricRegistry metricsRegistry) |
default InnerTableScan |
InnerTableScan.withMetricsRegistry(MetricRegistry metricRegistry) |
| Modifier and Type | Method and Description |
|---|---|
SnapshotReader |
SnapshotReader.withMetricRegistry(MetricRegistry registry) |
SnapshotReader |
SnapshotReaderImpl.withMetricRegistry(MetricRegistry registry) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.