@InterfaceAudience.Private public class MetricsTableSourceImpl extends java.lang.Object implements MetricsTableSource
TABLE_SIZE, TABLE_SIZE_DESC
Constructor and Description |
---|
MetricsTableSourceImpl(java.lang.String tblName,
MetricsTableAggregateSourceImpl aggregate,
MetricsTableWrapperAggregate tblWrapperAgg) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the table's metrics as all the region are closing.
|
int |
compareTo(MetricsTableSource source) |
boolean |
equals(java.lang.Object o) |
MetricsTableAggregateSource |
getAggregateSource()
Get the aggregate source to which this reports.
|
java.lang.String |
getTableName() |
java.lang.String |
getTableNamePrefix() |
MetricsTableWrapperAggregate |
getTableWrapper() |
int |
hashCode() |
void |
incrSplitRequest()
Increment number of a requested splits
|
void |
incrSplitSuccess()
Increment number of successful splits
|
void |
registerMetrics() |
void |
updateCompactionInputFileCount(boolean isMajor,
long c)
Update the compaction input number of files histogram
|
void |
updateCompactionInputSize(boolean isMajor,
long bytes)
Update the compaction total input file size histogram
|
void |
updateCompactionOutputFileCount(boolean isMajor,
long c)
Update the compaction output number of files histogram
|
void |
updateCompactionOutputSize(boolean isMajor,
long bytes)
Update the compaction total output file size
|
void |
updateCompactionTime(boolean isMajor,
long t)
Update the compaction time histogram, both major and minor
|
void |
updateFlushMemstoreSize(long bytes)
Update the flush memstore size histogram
|
void |
updateFlushOutputSize(long bytes)
Update the flush output file size histogram
|
void |
updateFlushTime(long t)
Update the flush time histogram
|
void |
updateSplitTime(long t)
Update the split transaction time histogram
|
public MetricsTableSourceImpl(java.lang.String tblName, MetricsTableAggregateSourceImpl aggregate, MetricsTableWrapperAggregate tblWrapperAgg)
public void registerMetrics()
registerMetrics
in interface MetricsTableSource
public void close()
MetricsTableSource
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface MetricsTableSource
public MetricsTableAggregateSource getAggregateSource()
MetricsTableSource
getAggregateSource
in interface MetricsTableSource
public int compareTo(MetricsTableSource source)
compareTo
in interface java.lang.Comparable<MetricsTableSource>
public java.lang.String getTableName()
getTableName
in interface MetricsTableSource
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public MetricsTableWrapperAggregate getTableWrapper()
public java.lang.String getTableNamePrefix()
public void incrSplitRequest()
MetricsTableSource
incrSplitRequest
in interface MetricsTableSource
public void incrSplitSuccess()
MetricsTableSource
incrSplitSuccess
in interface MetricsTableSource
public void updateSplitTime(long t)
MetricsTableSource
updateSplitTime
in interface MetricsTableSource
t
- time it took, in millisecondspublic void updateFlushTime(long t)
MetricsTableSource
updateFlushTime
in interface MetricsTableSource
t
- time it took, in millisecondspublic void updateFlushMemstoreSize(long bytes)
MetricsTableSource
updateFlushMemstoreSize
in interface MetricsTableSource
bytes
- the number of bytes in the memstorepublic void updateFlushOutputSize(long bytes)
MetricsTableSource
updateFlushOutputSize
in interface MetricsTableSource
bytes
- the number of bytes in the output filepublic void updateCompactionTime(boolean isMajor, long t)
MetricsTableSource
updateCompactionTime
in interface MetricsTableSource
isMajor
- whether compaction is a major compactiont
- time it took, in millisecondspublic void updateCompactionInputFileCount(boolean isMajor, long c)
MetricsTableSource
updateCompactionInputFileCount
in interface MetricsTableSource
isMajor
- whether compaction is a major compactionc
- number of filespublic void updateCompactionInputSize(boolean isMajor, long bytes)
MetricsTableSource
updateCompactionInputSize
in interface MetricsTableSource
isMajor
- whether compaction is a major compactionbytes
- the number of bytes of the compaction input filepublic void updateCompactionOutputFileCount(boolean isMajor, long c)
MetricsTableSource
updateCompactionOutputFileCount
in interface MetricsTableSource
isMajor
- whether compaction is a major compactionc
- number of filespublic void updateCompactionOutputSize(boolean isMajor, long bytes)
MetricsTableSource
updateCompactionOutputSize
in interface MetricsTableSource
isMajor
- whether compaction is a major compactionbytes
- the number of bytes of the compaction input file