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.