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.
|
isThreadSafepublic 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 ReadAccessorjava.lang.Exception - if opening the resource failedpublic void closeForRead()
throws java.lang.Exception
closeForRead in interface ReadAccessorjava.lang.Exception - if closing the resource failedpublic OneRow readNextObject() throws java.io.IOException
readNextObject in interface ReadAccessorjava.io.IOException