THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public class CommitMetrics { private final String GROUP_NAME = "commitMetricGroup"; private final String LAST_COMMIT_DURATION_METRIC = "lastCommitDuration"; ... private MetricGroup group; public CommitMetrics() { this.group = new MetricsGroup(GROUP_NAME); getMetricsInstance().addGroup(GROUP_NAME, group); } private void registerCommitMetrics() { group.gauge(LAST_COMMIT_DURATION_METRIC, new CommitDurationTimerCommitDurationGauge()); ... } } |
CommitMetrics
list includes commit duration, counter of files / records etc.
...
Code Block |
---|
public class ScanMetrics { private final String GROUP_NAME = "scanMetricGroup"; private final String LAST_SCAN_FILESSKIPPED_MANIFESTS_METRIC = "lastScanDurationlastScanSkippedManifests"; ... private MetricGroup group; public ScanMetrics() { this.group = new MetricsGroup(GROUP_NAME); getMetricsInstance().addGroup(GROUP_NAME, group); } private void registerScanMetrics() { group.counter(LAST_SCAN_SKIPPED_FILESMANIFESTS_METRIC, new ScanFilesCounterLastScanSkippedManifestsGauge()); ... } } |
ScanMetrics
list includes duration, data files and manifest files counter.
...
Code Block |
---|
public class CompactionMetrics { private final String GROUP_NAME = "compactionMetricGroup"; private final String LAST_TABLE_FILES_COMPACTED_FILESBEFORE_METRIC = "lastCompactionDurationlastTableFilesCompactedBefore"; ... private MetricGroup group; public CompactionMetrics() { this.group = new MetricsGroup(GROUP_NAME); getMetricsInstance().addGroup(GROUP_NAME, group); } private void registerScanMetrics() { group.counter(LAST_TABLE_FILES_COMPACTED_FILESBEFORE_METRIC, new CompactedFilesCounterLastTableFilesCompactedBeforeGauge()); ... } } |
CompactionMetrics
list includes duration, and counter of files, sorted runs etc.
...