1
2
3
4
5
6
7
8
9
10
11 package org.apache.hadoop.hbase.replication;
12
13 import org.apache.hadoop.hbase.classification.InterfaceAudience;
14
15
16
17
18 @InterfaceAudience.Private
19 public class ReplicationLoadSource {
20 private String peerID;
21 private long ageOfLastShippedOp;
22 private int sizeOfLogQueue;
23 private long timeStampOfLastShippedOp;
24 private long replicationLag;
25
26 public ReplicationLoadSource(String id, long age, int size, long timeStamp, long lag) {
27 this.peerID = id;
28 this.ageOfLastShippedOp = age;
29 this.sizeOfLogQueue = size;
30 this.timeStampOfLastShippedOp = timeStamp;
31 this.replicationLag = lag;
32 }
33
34 public String getPeerID() {
35 return this.peerID;
36 }
37
38 public long getAgeOfLastShippedOp() {
39 return this.ageOfLastShippedOp;
40 }
41
42 public long getSizeOfLogQueue() {
43 return this.sizeOfLogQueue;
44 }
45
46 public long getTimeStampOfLastShippedOp() {
47 return this.timeStampOfLastShippedOp;
48 }
49
50 public long getReplicationLag() {
51 return this.replicationLag;
52 }
53 }