org.apache.hadoop.hbase.replication.regionserver
Class ReplicationSinkMetrics

java.lang.Object
  extended by org.apache.hadoop.hbase.replication.regionserver.ReplicationSinkMetrics
All Implemented Interfaces:
org.apache.hadoop.metrics.Updater

public class ReplicationSinkMetrics
extends Object
implements org.apache.hadoop.metrics.Updater

This class is for maintaining the various replication statistics for a sink and publishing them through the metrics interfaces.


Field Summary
 MetricsRate appliedBatchesRate
          Rate of batches (of operations) applied by the sink
 MetricsRate appliedOpsRate
          Rate of operations applied by the sink
 
Constructor Summary
ReplicationSinkMetrics()
          Constructor used to register the metrics
 
Method Summary
 void doUpdates(org.apache.hadoop.metrics.MetricsContext metricsContext)
           
 void setAgeOfLastAppliedOp(long timestamp)
          Set the age of the last edit that was applied
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

appliedOpsRate

public final MetricsRate appliedOpsRate
Rate of operations applied by the sink


appliedBatchesRate

public final MetricsRate appliedBatchesRate
Rate of batches (of operations) applied by the sink

Constructor Detail

ReplicationSinkMetrics

public ReplicationSinkMetrics()
Constructor used to register the metrics

Method Detail

setAgeOfLastAppliedOp

public void setAgeOfLastAppliedOp(long timestamp)
Set the age of the last edit that was applied

Parameters:
timestamp - write time of the edit

doUpdates

public void doUpdates(org.apache.hadoop.metrics.MetricsContext metricsContext)
Specified by:
doUpdates in interface org.apache.hadoop.metrics.Updater


Copyright © 2011 The Apache Software Foundation. All Rights Reserved.