Package org.apache.hadoop.hbase.replication.regionserver

Interface MetricsReplicationSourceSource

All Superinterfaces:

BaseSource

All Known Subinterfaces:

MetricsReplicationGlobalSourceSource

All Known Implementing Classes:

MetricsReplicationGlobalSourceSourceImpl, MetricsReplicationSourceSourceImpl

@Private
public interface MetricsReplicationSourceSource
extends BaseSource

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SOURCE_AGE_OF_LAST_SHIPPED_OP
static final String	SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH
static final String	SOURCE_COMPLETED_LOGS
static final String	SOURCE_COMPLETED_RECOVERY_QUEUES
static final String	SOURCE_FAILED_BATCHES
static final String	SOURCE_FAILED_RECOVERY_QUEUES
static final String	SOURCE_INITIALIZING
static final String	SOURCE_LOG_EDITS_FILTERED
static final String	SOURCE_LOG_READ_IN_BYTES
static final String	SOURCE_LOG_READ_IN_EDITS
static final String	SOURCE_REPEATED_LOG_FILE_BYTES
static final String	SOURCE_RESTARTED_LOG_READING
static final String	SOURCE_SHIPPED_BATCHES
static final String	SOURCE_SHIPPED_BYTES
static final String	SOURCE_SHIPPED_HFILES
static final String	SOURCE_SHIPPED_OPS
static final String	SOURCE_SIZE_OF_HFILE_REFS_QUEUE
static final String	SOURCE_SIZE_OF_LOG_QUEUE
static final String	SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES
static final String	SOURCE_UNCLEANLY_CLOSED_LOGS

Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

HBASE_METRICS_SYSTEM_NAME

Method Summary

Modifier and Type	Method	Description
void	clear()
void	decrSizeOfHFileRefsQueue(long size)
void	decrSizeOfLogQueue(int size)
void	decrSourceInitializing()
long	getEditsFiltered()
long	getLastShippedAge()
long	getOldestWalAge()
long	getShippedOps()
int	getSizeOfLogQueue()
int	getSourceInitializing()
long	getUncleanlyClosedWALs()
long	getWALEditsRead()
void	incrBatchesShipped(int batches)
void	incrBytesSkippedInUncleanlyClosedWALs(long bytes)
void	incrCompletedRecoveryQueue()
void	incrCompletedWAL()
void	incrFailedBatches()
void	incrFailedRecoveryQueue()
void	incrHFilesShipped(long hfiles)
void	incrLogEditsFiltered(long size)
void	incrLogReadInBytes(long size)
void	incrLogReadInEdits(long size)
void	incrOpsShipped(long ops)
void	incrRepeatedFileBytes(long bytes)
void	incrRestartedWALReading()
void	incrShippedBytes(long size)
void	incrSizeOfHFileRefsQueue(long size)
void	incrSizeOfLogQueue(int size)
void	incrSourceInitializing()
void	incrUncleanlyClosedWALs()
void	incrUnknownFileLengthForClosedWAL()
void	setLastShippedAge(long age)
void	setOldestWalAge(long age)

Methods inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram

Field Details

SOURCE_SIZE_OF_LOG_QUEUE

static final String SOURCE_SIZE_OF_LOG_QUEUE

See Also:

• Constant Field Values

SOURCE_AGE_OF_LAST_SHIPPED_OP

static final String SOURCE_AGE_OF_LAST_SHIPPED_OP

See Also:

• Constant Field Values

SOURCE_SHIPPED_BATCHES

static final String SOURCE_SHIPPED_BATCHES

See Also:

• Constant Field Values

SOURCE_FAILED_BATCHES

static final String SOURCE_FAILED_BATCHES

See Also:

• Constant Field Values

SOURCE_SHIPPED_BYTES

static final String SOURCE_SHIPPED_BYTES

See Also:

• Constant Field Values

SOURCE_SHIPPED_OPS

static final String SOURCE_SHIPPED_OPS

See Also:

• Constant Field Values

SOURCE_LOG_READ_IN_BYTES

static final String SOURCE_LOG_READ_IN_BYTES

See Also:

• Constant Field Values

SOURCE_LOG_READ_IN_EDITS

static final String SOURCE_LOG_READ_IN_EDITS

See Also:

• Constant Field Values

SOURCE_LOG_EDITS_FILTERED

static final String SOURCE_LOG_EDITS_FILTERED

See Also:

• Constant Field Values

SOURCE_SHIPPED_HFILES

static final String SOURCE_SHIPPED_HFILES

See Also:

• Constant Field Values

SOURCE_SIZE_OF_HFILE_REFS_QUEUE

static final String SOURCE_SIZE_OF_HFILE_REFS_QUEUE

See Also:

• Constant Field Values

SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH

static final String SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH

See Also:

• Constant Field Values

SOURCE_UNCLEANLY_CLOSED_LOGS

static final String SOURCE_UNCLEANLY_CLOSED_LOGS

See Also:

• Constant Field Values

SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES

static final String SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES

See Also:

• Constant Field Values

SOURCE_RESTARTED_LOG_READING

static final String SOURCE_RESTARTED_LOG_READING

See Also:

• Constant Field Values

SOURCE_REPEATED_LOG_FILE_BYTES

static final String SOURCE_REPEATED_LOG_FILE_BYTES

See Also:

• Constant Field Values

SOURCE_COMPLETED_LOGS

static final String SOURCE_COMPLETED_LOGS

See Also:

• Constant Field Values

SOURCE_COMPLETED_RECOVERY_QUEUES

static final String SOURCE_COMPLETED_RECOVERY_QUEUES

See Also:

• Constant Field Values

SOURCE_FAILED_RECOVERY_QUEUES

static final String SOURCE_FAILED_RECOVERY_QUEUES

See Also:

• Constant Field Values

SOURCE_INITIALIZING

static final String SOURCE_INITIALIZING

See Also:

• Constant Field Values

Method Details

setLastShippedAge

void setLastShippedAge(long age)

incrSizeOfLogQueue

void incrSizeOfLogQueue(int size)

decrSizeOfLogQueue

void decrSizeOfLogQueue(int size)

incrLogEditsFiltered

void incrLogEditsFiltered(long size)

incrBatchesShipped

void incrBatchesShipped(int batches)

incrFailedBatches

void incrFailedBatches()

incrOpsShipped

void incrOpsShipped(long ops)

incrShippedBytes

void incrShippedBytes(long size)

incrLogReadInBytes

void incrLogReadInBytes(long size)

incrLogReadInEdits

void incrLogReadInEdits(long size)

clear

void clear()

getLastShippedAge

long getLastShippedAge()

getSizeOfLogQueue

int getSizeOfLogQueue()

incrHFilesShipped

void incrHFilesShipped(long hfiles)

incrSizeOfHFileRefsQueue

void incrSizeOfHFileRefsQueue(long size)

decrSizeOfHFileRefsQueue

void decrSizeOfHFileRefsQueue(long size)

incrUnknownFileLengthForClosedWAL

void incrUnknownFileLengthForClosedWAL()

incrUncleanlyClosedWALs

void incrUncleanlyClosedWALs()

getUncleanlyClosedWALs

long getUncleanlyClosedWALs()

incrBytesSkippedInUncleanlyClosedWALs

void incrBytesSkippedInUncleanlyClosedWALs(long bytes)

incrRestartedWALReading

void incrRestartedWALReading()

incrRepeatedFileBytes

void incrRepeatedFileBytes(long bytes)

incrCompletedWAL

void incrCompletedWAL()

incrCompletedRecoveryQueue

void incrCompletedRecoveryQueue()

incrFailedRecoveryQueue

void incrFailedRecoveryQueue()

getWALEditsRead

long getWALEditsRead()

getShippedOps

long getShippedOps()

getEditsFiltered

long getEditsFiltered()

setOldestWalAge

void setOldestWalAge(long age)

getOldestWalAge

long getOldestWalAge()

incrSourceInitializing

void incrSourceInitializing()

decrSourceInitializing

void decrSourceInitializing()

getSourceInitializing

int getSourceInitializing()