Package org.apache.hadoop.hbase.coprocessor.example.row.stats

Class RowStatisticsImpl

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.row.stats.RowStatisticsImpl

All Implemented Interfaces:

RowStatistics

@Private
public class RowStatisticsImpl
extends Object
implements RowStatistics

Holder for accumulating row statistics in RowStatisticsCompactionObserver Creates various cell, row, and total stats.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	blockSize
private int	cellsLargerThanMaxCacheSizeCount
private int	cellsLargerThanOneBlockCount
private final String	columnFamily
private static final org.apache.hbase.thirdparty.com.google.gson.Gson	GSON
private final boolean	isMajor
private Cell	largestCell
private long	largestCellNumBytes
private Cell	largestCellRef
private byte[]	largestRow
private int	largestRowCellsCount
private long	largestRowNumBytes
private Cell	largestRowRef
private static final org.slf4j.Logger	LOG
private final long	maxCacheSize
private final String	region
private long	rowBytes
private int	rowCells
private final SizeBucketTracker	rowSizeBuckets
private int	rowsLargerThanOneBlockCount
private final String	table
private long	totalBytesCount
private int	totalCellsCount
private int	totalDeletesCount
private int	totalRowsCount
private final SizeBucketTracker	valueSizeBuckets

Constructor Summary

Constructors

Constructor	Description
RowStatisticsImpl(String table, String encodedRegion, String columnFamily, long blockSize, long maxCacheSize, boolean isMajor)

Method Summary

Modifier and Type	Method	Description
private org.apache.hbase.thirdparty.com.google.gson.JsonObject	buildLargestCellPartsJson()
void	consumeCell(Cell cell)
int	getCellsLargerThanMaxCacheSizeCount()
int	getCellsLargerThanOneBlockCount()
String	getColumnFamily()
String	getJsonString()
Cell	getLargestCell()
String	getLargestCellAsString()
long	getLargestCellNumBytes()
byte[]	getLargestRow()
String	getLargestRowAsString()
int	getLargestRowCellsCount()
long	getLargestRowNumBytes()
String	getRegion()
Map<String,Long>	getRowSizeBuckets()
int	getRowsLargerThanOneBlockCount()
String	getTable()
long	getTotalBytes()
int	getTotalCellsCount()
int	getTotalDeletesCount()
int	getTotalRowsCount()
Map<String,Long>	getValueSizeBuckets()
void	handleRowChanged(Cell lastCell)
boolean	isMajor()
void	shipped(RawCellBuilder cellBuilder)	Clone the cell refs so they can be cleaned up by Shipper.shipped().
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

GSON

private static final org.apache.hbase.thirdparty.com.google.gson.Gson GSON

blockSize

private final transient long blockSize

maxCacheSize

private final transient long maxCacheSize

rowCells

private transient int rowCells

rowBytes

private transient long rowBytes

largestRow

private transient byte[] largestRow

largestCell

private transient Cell largestCell

isMajor

private final transient boolean isMajor

rowSizeBuckets

private final transient SizeBucketTracker rowSizeBuckets

valueSizeBuckets

private final transient SizeBucketTracker valueSizeBuckets

largestRowRef

private transient Cell largestRowRef

largestCellRef

private transient Cell largestCellRef

table

private final String table

region

private final String region

columnFamily

private final String columnFamily

largestRowNumBytes

private long largestRowNumBytes

largestRowCellsCount

private int largestRowCellsCount

largestCellNumBytes

private long largestCellNumBytes

cellsLargerThanOneBlockCount

private int cellsLargerThanOneBlockCount

rowsLargerThanOneBlockCount

private int rowsLargerThanOneBlockCount

cellsLargerThanMaxCacheSizeCount

private int cellsLargerThanMaxCacheSizeCount

totalDeletesCount

private int totalDeletesCount

totalCellsCount

private int totalCellsCount

totalRowsCount

private int totalRowsCount

totalBytesCount

private long totalBytesCount

Constructor Details

RowStatisticsImpl

RowStatisticsImpl(String table,
 String encodedRegion,
 String columnFamily,
 long blockSize,
 long maxCacheSize,
 boolean isMajor)

Method Details

handleRowChanged

public void handleRowChanged(Cell lastCell)

consumeCell

public void consumeCell(Cell cell)

shipped

public void shipped(RawCellBuilder cellBuilder)

Clone the cell refs so they can be cleaned up by Shipper.shipped(). Doing this lazily here, rather than eagerly in the above two methods can save us on some allocations. We might change the largestCell/largestRow multiple times between shipped() calls.

getTable

public String getTable()

Specified by:

getTable in interface RowStatistics

getRegion

public String getRegion()

Specified by:

getRegion in interface RowStatistics

getColumnFamily

public String getColumnFamily()

Specified by:

getColumnFamily in interface RowStatistics

isMajor

public boolean isMajor()

Specified by:

isMajor in interface RowStatistics

getLargestRow

public byte[] getLargestRow()

getLargestRowAsString

public String getLargestRowAsString()

Specified by:

getLargestRowAsString in interface RowStatistics

getLargestRowNumBytes

public long getLargestRowNumBytes()

Specified by:

getLargestRowNumBytes in interface RowStatistics

getLargestRowCellsCount

public int getLargestRowCellsCount()

Specified by:

getLargestRowCellsCount in interface RowStatistics

getLargestCell

public Cell getLargestCell()

getLargestCellAsString

public String getLargestCellAsString()

Specified by:

getLargestCellAsString in interface RowStatistics

getLargestCellNumBytes

public long getLargestCellNumBytes()

Specified by:

getLargestCellNumBytes in interface RowStatistics

getCellsLargerThanOneBlockCount

public int getCellsLargerThanOneBlockCount()

Specified by:

getCellsLargerThanOneBlockCount in interface RowStatistics

getRowsLargerThanOneBlockCount

public int getRowsLargerThanOneBlockCount()

Specified by:

getRowsLargerThanOneBlockCount in interface RowStatistics

getCellsLargerThanMaxCacheSizeCount

public int getCellsLargerThanMaxCacheSizeCount()

Specified by:

getCellsLargerThanMaxCacheSizeCount in interface RowStatistics

getTotalDeletesCount

public int getTotalDeletesCount()

Specified by:

getTotalDeletesCount in interface RowStatistics

getTotalCellsCount

public int getTotalCellsCount()

Specified by:

getTotalCellsCount in interface RowStatistics

getTotalRowsCount

public int getTotalRowsCount()

Specified by:

getTotalRowsCount in interface RowStatistics

getTotalBytes

public long getTotalBytes()

Specified by:

getTotalBytes in interface RowStatistics

getRowSizeBuckets

public Map<String,Long> getRowSizeBuckets()

Specified by:

getRowSizeBuckets in interface RowStatistics

getValueSizeBuckets

public Map<String,Long> getValueSizeBuckets()

Specified by:

getValueSizeBuckets in interface RowStatistics

toString

public String toString()

Overrides:

toString in class Object

getJsonString

public String getJsonString()

Specified by:

getJsonString in interface RowStatistics

buildLargestCellPartsJson

private org.apache.hbase.thirdparty.com.google.gson.JsonObject buildLargestCellPartsJson()