Versions Compared

Key

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

...

Code Block
languagejava
public class MetricGroup {
	private final String groupName;

	/** Constructor of MetricGroup. */
	public MetricGroup(String groupName) {
		this.groupName = groupName;
	}
	
	/** tags of metric group. */
	private final Map<String, Set<String>> tags = new HashMap<>();

	/** Map of gauge metrics. */
    private final Map<String, Gauge<?>> gauges = new HashMap<>();

    /** Map of counter metrics. */
    private final Map<String, Counter> counters = new HashMap<>();

	/** Map of counter metrics. */
    private final Map<String, Histogram> histograms = new HashMap<>();

   /** Register gauge metric. */
 	public void gauge(String name, Gauge gauge) {}

	/** Register counter metric. */
	public void counter(String name, Counter counter) {}

	/** Register histogram metric. */
	public void histogram(String name, Histogram counter) {}

	/** Add tag for metric group. */
	public void addTag(String tag, String value) {}
}

...

Code Block
languagejava
public class CommitMetrics {
	private Metrics metrics;
	private final String COMMIT_DURATION_METRIC = "lastCommitDuration";
	...
	private void registerCommitMetrics(Metrics metrics MetricGroup group;

	public CommitMetrics() {
		metricsString gruopName = "commitMetricGroup";
		this.group = new MetricsGroup(gruopName);
  		getMetricsInstance().addGroup(gruopName, group);
	}
	private void registerCommitMetrics() {   
		group.gauge(COMMIT_DURATION_METRIC, new CommitDurationTimer());
		...
	}
	...
}

CommitMetrics list includes commit duration, counter of files / records etc.

...

Code Block
public class ScanMetrics {
	private Metrics metrics;
	private final String SCAN_FILES_METRIC final String SCAN_FILES_METRIC = "lastScanDuration";
	...
 	private MetricGroup group;

	public ScanMetrics() {
		String gruopName = "lastScanDurationscanMetricGroup";
		this...group = new MetricsGroup(gruopName);
  		getMetricsInstance().addGroup(gruopName, group);
	}
   	
	private void registerScanMetrics(Metrics metrics) {   
		metricsgroup.counter(SCAN_FILES_METRIC, new ScanFilesCounter());
		...
	}
	...
}

ScanMetrics list includes duration, data files and manifest files counter.

...