org.apache.hadoop.hbase.replication.regionserver

Class MetricsReplicationSourceSourceImpl

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSourceImpl

All Implemented Interfaces:

MetricsReplicationSourceSource

public class MetricsReplicationSourceSourceImpl
extends Object
implements MetricsReplicationSourceSource

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource

SOURCE_AGE_OF_LAST_SHIPPED_OP, SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH, SOURCE_COMPLETED_LOGS, SOURCE_COMPLETED_RECOVERY_QUEUES, SOURCE_LOG_EDITS_FILTERED, SOURCE_LOG_READ_IN_BYTES, SOURCE_LOG_READ_IN_EDITS, SOURCE_REPEATED_LOG_FILE_BYTES, SOURCE_RESTARTED_LOG_READING, SOURCE_SHIPPED_BATCHES, SOURCE_SHIPPED_KBS, SOURCE_SHIPPED_OPS, SOURCE_SIZE_OF_LOG_QUEUE, SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES, SOURCE_UNCLEANLY_CLOSED_LOGS

Constructor Summary

Constructors

Constructor and Description
MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms, String id)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
void	decrSizeOfLogQueue(int size)
long	getLastShippedAge()
void	incrBatchesShipped(int batches)
void	incrBytesSkippedInUncleanlyClosedWALs(long bytes)
void	incrCompletedRecoveryQueue()
void	incrCompletedWAL()
void	incrLogEditsFiltered(long size)
void	incrLogReadInBytes(long size)
void	incrLogReadInEdits(long size)
void	incrOpsShipped(long ops)
void	incrRepeatedFileBytes(long bytes)
void	incrRestartedWALReading()
void	incrShippedKBs(long size)
void	incrSizeOfLogQueue(int size)
void	incrUncleanlyClosedWALs()
void	incrUnknownFileLengthForClosedWAL()
void	setLastShippedAge(long age)
void	setSizeOfLogQueue(int size)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsReplicationSourceSourceImpl

public MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms,
                                  String id)

Method Detail

setLastShippedAge

public void setLastShippedAge(long age)

Specified by:

setLastShippedAge in interface MetricsReplicationSourceSource

setSizeOfLogQueue

public void setSizeOfLogQueue(int size)

Specified by:

setSizeOfLogQueue in interface MetricsReplicationSourceSource

incrSizeOfLogQueue

public void incrSizeOfLogQueue(int size)

Specified by:

incrSizeOfLogQueue in interface MetricsReplicationSourceSource

decrSizeOfLogQueue

public void decrSizeOfLogQueue(int size)

Specified by:

decrSizeOfLogQueue in interface MetricsReplicationSourceSource

incrLogReadInEdits

public void incrLogReadInEdits(long size)

Specified by:

incrLogReadInEdits in interface MetricsReplicationSourceSource

incrLogEditsFiltered

public void incrLogEditsFiltered(long size)

Specified by:

incrLogEditsFiltered in interface MetricsReplicationSourceSource

incrBatchesShipped

public void incrBatchesShipped(int batches)

Specified by:

incrBatchesShipped in interface MetricsReplicationSourceSource

incrOpsShipped

public void incrOpsShipped(long ops)

Specified by:

incrOpsShipped in interface MetricsReplicationSourceSource

incrShippedKBs

public void incrShippedKBs(long size)

Specified by:

incrShippedKBs in interface MetricsReplicationSourceSource

incrLogReadInBytes

public void incrLogReadInBytes(long size)

Specified by:

incrLogReadInBytes in interface MetricsReplicationSourceSource

clear

public void clear()

Specified by:

clear in interface MetricsReplicationSourceSource

getLastShippedAge

public long getLastShippedAge()

Specified by:

getLastShippedAge in interface MetricsReplicationSourceSource

incrUnknownFileLengthForClosedWAL

public void incrUnknownFileLengthForClosedWAL()

Specified by:

incrUnknownFileLengthForClosedWAL in interface MetricsReplicationSourceSource

incrUncleanlyClosedWALs

public void incrUncleanlyClosedWALs()

Specified by:

incrUncleanlyClosedWALs in interface MetricsReplicationSourceSource

incrBytesSkippedInUncleanlyClosedWALs

public void incrBytesSkippedInUncleanlyClosedWALs(long bytes)

Specified by:

incrBytesSkippedInUncleanlyClosedWALs in interface MetricsReplicationSourceSource

incrRestartedWALReading

public void incrRestartedWALReading()

Specified by:

incrRestartedWALReading in interface MetricsReplicationSourceSource

incrRepeatedFileBytes

public void incrRepeatedFileBytes(long bytes)

Specified by:

incrRepeatedFileBytes in interface MetricsReplicationSourceSource

incrCompletedWAL

public void incrCompletedWAL()

Specified by:

incrCompletedWAL in interface MetricsReplicationSourceSource

incrCompletedRecoveryQueue

public void incrCompletedRecoveryQueue()

Specified by:

incrCompletedRecoveryQueue in interface MetricsReplicationSourceSource