public class HBaseAccessor extends Plugin implements ReadAccessor
The table is divided into several splits. Each accessor instance is assigned a single split. For each region, a Scan object is used to describe the requested rows.
The class supports filters using the HBaseFilterBuilder
.
Regions can be filtered out according to input from HBaseFilterBuilder
.
Constructor and Description |
---|
HBaseAccessor(InputData input)
Constructs
HBaseTupleDescription based on HAWQ table description and
initializes the scan start and end keys of the HBase table to default values. |
Modifier and Type | Method and Description |
---|---|
void |
closeForRead()
Closes the HBase table.
|
boolean |
openForRead()
Opens the HBase table.
|
OneRow |
readNextObject()
Returns the next row in the HBase table, null if end of fragment.
|
isThreadSafe
public HBaseAccessor(InputData input)
HBaseTupleDescription
based on HAWQ table description and
initializes the scan start and end keys of the HBase table to default values.input
- query information, contains HBase table name and filterpublic boolean openForRead() throws java.lang.Exception
openForRead
in interface ReadAccessor
java.lang.Exception
- if opening the resource failedpublic void closeForRead() throws java.lang.Exception
closeForRead
in interface ReadAccessor
java.lang.Exception
- if closing the resource failedpublic OneRow readNextObject() throws java.io.IOException
readNextObject
in interface ReadAccessor
java.io.IOException