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.MutableCounterLong;
22 import org.apache.hadoop.metrics2.lib.MutableGaugeLong;
23
24 public class MetricsReplicationSinkSourceImpl implements MetricsReplicationSinkSource {
25
26 private final MutableGaugeLong ageGauge;
27 private final MutableCounterLong batchesCounter;
28 private final MutableCounterLong opsCounter;
29
30 public MetricsReplicationSinkSourceImpl(MetricsReplicationSourceImpl rms) {
31 ageGauge = rms.getMetricsRegistry().getLongGauge(SINK_AGE_OF_LAST_APPLIED_OP, 0L);
32 batchesCounter = rms.getMetricsRegistry().getLongCounter(SINK_APPLIED_BATCHES, 0L);
33 opsCounter = rms.getMetricsRegistry().getLongCounter(SINK_APPLIED_OPS, 0L);
34 }
35
36 @Override public void setLastAppliedOpAge(long age) {
37 ageGauge.set(age);
38 }
39
40 @Override public void incrAppliedBatches(long batches) {
41 batchesCounter.incr(batches);
42 }
43
44 @Override public void incrAppliedOps(long batchsize) {
45 opsCounter.incr(batchsize);
46 }
47
48 @Override
49 public long getLastAppliedOpAge() {
50 return ageGauge.value();
51 }
52 }