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 |
---|---|
FallbackReadFileStoreTable.FallbackReadScan |
FallbackReadFileStoreTable.FallbackReadScan.withMetricRegistry(MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
InnerTableCommit |
TableCommitImpl.withMetricRegistry(MetricRegistry registry) |
TableCommit |
TableCommit.withMetricRegistry(MetricRegistry registry)
Set
MetricRegistry to table commit. |
TableWriteImpl<T> |
TableWriteImpl.withMetricRegistry(MetricRegistry metricRegistry) |
InnerTableCommit |
InnerTableCommit.withMetricRegistry(MetricRegistry registry) |
TableWrite |
TableWrite.withMetricRegistry(MetricRegistry registry)
Set
MetricRegistry to table write. |
Modifier and Type | Method and Description |
---|---|
TableRead |
TableRead.withMetricRegistry(MetricRegistry registry)
Set
MetricRegistry to table read. |
default InnerTableRead |
InnerTableRead.withMetricRegistry(MetricRegistry registry) |
default InnerTableScan |
InnerTableScan.withMetricRegistry(MetricRegistry metricRegistry) |
TableScan |
TableScan.withMetricRegistry(MetricRegistry registry)
Set
MetricRegistry to table scan. |
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.