org.apache.hadoop.hbase.replication.regionserver

Class ReplicationLoad

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.ReplicationLoad

@InterfaceAudience.Private
public class ReplicationLoad
extends Object

This class is used for exporting some of the info from replication metrics

Field Summary

Fields

Modifier and Type	Field and Description
static ReplicationLoad	EMPTY_REPLICATIONLOAD
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSink	replicationLoadSink
private List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSource>	replicationLoadSourceList
private MetricsSink	sinkMetrics
private List<MetricsSource>	sourceMetricsList

Constructor Summary

Constructors

Constructor and Description
ReplicationLoad() default constructor

Method Summary

Modifier and Type	Method and Description
void	buildReplicationLoad(List<MetricsSource> srMetricsList, MetricsSink skMetrics) buildReplicationLoad
(package private) static long	calculateReplicationDelay(long ageOfLastShippedOp, long timeStampOfLastShippedOp, int sizeOfLogQueue)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSink	getReplicationLoadSink()
List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSource>	getReplicationLoadSourceList()
String	sinkToString() sinkToString
String	sourceToString() sourceToString
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

EMPTY_REPLICATIONLOAD

public static final ReplicationLoad EMPTY_REPLICATIONLOAD

sourceMetricsList

private List<MetricsSource> sourceMetricsList

sinkMetrics

private MetricsSink sinkMetrics

replicationLoadSourceList

private List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSource> replicationLoadSourceList

replicationLoadSink

private org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSink replicationLoadSink

Constructor Detail

ReplicationLoad

public ReplicationLoad()

default constructor

Method Detail

buildReplicationLoad

public void buildReplicationLoad(List<MetricsSource> srMetricsList,
                                 MetricsSink skMetrics)

buildReplicationLoad

Parameters:

srMetricsList -

skMetrics -

calculateReplicationDelay

static long calculateReplicationDelay(long ageOfLastShippedOp,
                                      long timeStampOfLastShippedOp,
                                      int sizeOfLogQueue)

sourceToString

public String sourceToString()

sourceToString

Returns:

a string contains sourceReplicationLoad information

sinkToString

public String sinkToString()

sinkToString

Returns:

a string contains sinkReplicationLoad information

getReplicationLoadSink

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSink getReplicationLoadSink()

getReplicationLoadSourceList

public List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.ReplicationLoadSource> getReplicationLoadSourceList()

toString

public String toString()

Overrides:

toString in class Object

See Also:

Object.toString()