Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
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.

...