...
Metric Name | Description | Type | Tagged | Unit | Update at |
lastScanDuration | The time it took to complete the last scan planning. | Gauge | none | Ms | Timer starts before the scan planning starts, update after the last scan planning operation finished |
scanDuration | Distributions of the time taken by the last few scan planning operations. | Histogram | none | Ms | Timer starts before the scan planning starts, update after each planning finished |
lastScannedManifests | Number of scanned manifests files in the last scan planning. | Gauge | none | Number | Scan planning |
lastScanSkippedManifests | Number of skipped manifests files in the last scan planning. | Gauge | none | Number | Scan planning |
lastScanResultTableFiles | Number of result table files in the last scan planning. | Gauge | none | Number | Scan planning |
lastScanGenerateSplits | Number of splits generated by the last scan planning. | Gauge | none | Number | Scan planning |
CompactionMetrics
Code Block |
---|
public class CompactionMetrics { private final String LAST_TABLE_FILES_COMPACTED_BEFORE_METRIC = "lastTableFilesCompactedBefore"; ... private final Map<Integer, BucketMetricGroup> bucketMetricGroups = new HashMap<>(); private final Map<BinaryRow, PartitionMetricGroup> partitionMetricGroups = new HashMap<>(); private void registerTaggedCompactionMetrics() { if(isNewBucket()) { registerTaggedMetrics(); } if(isNewPartition()) { registerTaggedMetrics(); } } } |
...