1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.replication.regionserver;
20
21 import org.apache.hadoop.metrics2.lib.MutableFastCounter;
22 import org.apache.hadoop.metrics2.lib.MutableGaugeLong;
23
24 public class MetricsReplicationSinkSourceImpl implements MetricsReplicationSinkSource {
25
26 private final MutableGaugeLong ageGauge;
27 private final MutableFastCounter batchesCounter;
28 private final MutableFastCounter opsCounter;
29 private final MutableFastCounter hfilesCounter;
30
31 public MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms) {
32 ageGauge = rms.getMetricsRegistry().getGauge(SINK_AGE_OF_LAST_APPLIED_OP, 0L);
33 batchesCounter = rms.getMetricsRegistry().getCounter(SINK_APPLIED_BATCHES, 0L);
34 opsCounter = rms.getMetricsRegistry().getCounter(SINK_APPLIED_OPS, 0L);
35 hfilesCounter = rms.getMetricsRegistry().getCounter(SINK_APPLIED_HFILES, 0L);
36 }
37
38 @Override public void setLastAppliedOpAge(long age) {
39 ageGauge.set(age);
40 }
41
42 @Override public void incrAppliedBatches(long batches) {
43 batchesCounter.incr(batches);
44 }
45
46 @Override public void incrAppliedOps(long batchsize) {
47 opsCounter.incr(batchsize);
48 }
49
50 @Override
51 public long getLastAppliedOpAge() {
52 return ageGauge.value();
53 }
54
55 @Override
56 public void incrAppliedHFiles(long hfiles) {
57 hfilesCounter.incr(hfiles);
58 }
59 }