org.apache.hawq.pxf.plugins.hbase

Class HBaseResolver

java.lang.Object

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

org.apache.hawq.pxf.plugins.hbase.HBaseResolver

All Implemented Interfaces:

ReadResolver

public class HBaseResolver
extends Plugin
implements ReadResolver

Record resolver for HBase. The class is responsible to convert rows from HBase scans (returned as Result objects) into a List of OneField objects. That also includes the conversion process of each HBase column's value into its HAWQ assigned type. Currently, the class assumes all HBase values are stored as String object Bytes encoded.

Field Summary

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

inputData

Constructor Summary

Constructors

Constructor and Description
HBaseResolver(InputData input) Constructs a resolver and initializes the table's tuple description.

Method Summary

Modifier and Type	Method and Description
java.util.List<OneField>	getFields(OneRow onerow) Splits an HBase Result object into a list of OneField, based on the table's tuple description.

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

HBaseResolver

public HBaseResolver(InputData input)

Constructs a resolver and initializes the table's tuple description.

Parameters:

input - query information, contains HBase table name and filter

Method Detail

getFields

public java.util.List<OneField> getFields(OneRow onerow)
                                   throws java.lang.Exception

Splits an HBase Result object into a list of OneField, based on the table's tuple description. Each field is converted from HBase bytes into its column description type.

Specified by:

getFields in interface ReadResolver

Parameters:

onerow - the row to get the fields from

Returns:

list of fields

Throws:

java.lang.Exception - if decomposing the row into fields failed