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 and Description
static long	DEFAULT_ROW_COUNT

Constructor Summary

Constructors

Constructor and 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 and 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 Detail

DEFAULT_ROW_COUNT

public static final long DEFAULT_ROW_COUNT

See Also:

Constant Field Values

Constructor Detail

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 Detail

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()