Package org.apache.drill.exec.store.hbase

Class TableStatsCalculator

java.lang.Object

org.apache.drill.exec.store.hbase.TableStatsCalculator

public class TableStatsCalculator
extends Object

Computes size of each region for given table.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_ROW_COUNT

Constructor Summary

Constructors

Constructor	Description
TableStatsCalculator(org.apache.hadoop.hbase.client.Connection connection, HBaseScanSpec hbaseScanSpec, DrillConfig config, HBaseStoragePluginConfig storageConfig)	Computes size of each region for table.

Method Summary

Modifier and Type	Method	Description
int	getAvgRowSizeInBytes()
int	getColsPerRow()
long	getRegionSizeInBytes(byte[] regionId)	Returns size of given region in bytes.
boolean	usedDefaultRowCount()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_ROW_COUNT

public static final long DEFAULT_ROW_COUNT

See Also:

• Constant Field Values

Constructor Details

TableStatsCalculator

public TableStatsCalculator(org.apache.hadoop.hbase.client.Connection connection,
 HBaseScanSpec hbaseScanSpec,
 DrillConfig config,
 HBaseStoragePluginConfig storageConfig)
                     throws IOException

Computes size of each region for table.

Parameters:

connection - connection to Hbase client

hbaseScanSpec - scan specification

config - drill configuration

storageConfig - Hbase storage configuration

Throws:

IOException

Method Details

getRegionSizeInBytes

public long getRegionSizeInBytes(byte[] regionId)

Returns size of given region in bytes. Returns 0 if region was not found.

getAvgRowSizeInBytes

public int getAvgRowSizeInBytes()

getColsPerRow

public int getColsPerRow()

usedDefaultRowCount

public boolean usedDefaultRowCount()