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  }