org.apache.hawq.pxf.plugins.hbase

Class HBaseDataFragmenter

java.lang.Object

org.apache.hawq.pxf.api.utilities.Plugin

org.apache.hawq.pxf.api.Fragmenter

org.apache.hawq.pxf.plugins.hbase.HBaseDataFragmenter

public class HBaseDataFragmenter
extends Fragmenter

Fragmenter class for HBase data resources. Extends the Fragmenter abstract class, with the purpose of transforming an input data path (an HBase table name in this case) into a list of regions that belong to this table. This class also puts HBase lookup table information for the given table (if exists) in each fragment's user data field.

Field Summary

Fields inherited from class org.apache.hawq.pxf.api.Fragmenter

fragments

Fields inherited from class org.apache.hawq.pxf.api.utilities.Plugin

inputData

Constructor Summary

Constructors

Constructor and Description
HBaseDataFragmenter(InputData inConf) Constructor for HBaseDataFragmenter.

Method Summary

Modifier and Type	Method and Description
java.util.List<Fragment>	getFragments() Returns list of fragments containing all of the HBase's table data.
FragmentsStats	getFragmentsStats() Returns statistics for HBase table.

Methods inherited from class org.apache.hawq.pxf.api.utilities.Plugin

isThreadSafe

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseDataFragmenter

public HBaseDataFragmenter(InputData inConf)

Constructor for HBaseDataFragmenter.

Parameters:

inConf - input data such as which HBase table to scan

Method Detail

getFragmentsStats

public FragmentsStats getFragmentsStats()
                                 throws java.lang.Exception

Returns statistics for HBase table. Currently it's not implemented.

Overrides:

getFragmentsStats in class Fragmenter

Returns:

default statistics

Throws:

java.lang.Exception - if statistics cannot be gathered

getFragments

public java.util.List<Fragment> getFragments()
                                      throws java.lang.Exception

Returns list of fragments containing all of the HBase's table data. Lookup table information with mapping between field names in HAWQ table and HBase table will be returned as user data.

Specified by:

getFragments in class Fragmenter

Returns:

a list of fragments

Throws:

java.lang.Exception - if fragment list could not be retrieved