Constructor Detail

• MetricsSink

  public MetricsSink()

Method Detail

• setAgeOfLastAppliedOp

  public long setAgeOfLastAppliedOp(long timestamp)

  Set the age of the last applied operation

  Parameters:

  timestamp - The timestamp of the last operation applied.

  Returns:

  the age that was set

• refreshAgeOfLastAppliedOp

  public long refreshAgeOfLastAppliedOp()

  Refreshing the age makes sure the value returned is the actual one and not the one set a replication time

  Returns:

  refreshed age

• applyBatch

  public void applyBatch(long batchSize)

  Convience method to change metrics when a batch of operations are applied.

  Parameters:

  batchSize -

• applyBatch

  public void applyBatch(long batchSize,
                long hfileSize)

  Convience method to change metrics when a batch of operations are applied.

  Parameters:

  batchSize - total number of mutations that are applied/replicated

  hfileSize - total number of hfiles that are applied/replicated

• getAgeOfLastAppliedOp

  public long getAgeOfLastAppliedOp()

  Get the Age of Last Applied Op

  Returns:

  ageOfLastAppliedOp

• getTimeStampOfLastAppliedOp

  public long getTimeStampOfLastAppliedOp()

  Get the TimeStampOfLastAppliedOp. If no replication Op applied yet, the value is the timestamp at which hbase instance starts

  Returns:

  timeStampsOfLastAppliedOp;