THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
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 | ||
---|---|---|
| ||
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.
...