org.apache.drill.exec.store.hbase

Class HBaseUtils

java.lang.Object

org.apache.drill.exec.store.hbase.HBaseUtils

public class HBaseUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
HBaseUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.hbase.filter.Filter	andFilterAtIndex(org.apache.hadoop.hbase.filter.Filter currentFilter, int index, org.apache.hadoop.hbase.filter.Filter newFilter)
static org.apache.hadoop.hbase.filter.Filter	deserializeFilter(byte[] filterBytes)
static byte[]	getBytes(String str)
static byte[]	maxOfStartRows(byte[] left, byte[] right)
static byte[]	maxOfStopRows(byte[] left, byte[] right)
static byte[]	minOfStartRows(byte[] left, byte[] right)
static byte[]	minOfStopRows(byte[] left, byte[] right)
static org.apache.hadoop.hbase.filter.Filter	orFilterAtIndex(org.apache.hadoop.hbase.filter.Filter currentFilter, int index, org.apache.hadoop.hbase.filter.Filter newFilter)
static byte[]	serializeFilter(org.apache.hadoop.hbase.filter.Filter filter)
static void	verifyColumns(List<SchemaPath> columns, org.apache.hadoop.hbase.HTableDescriptor hTableDesc) Verify the presence of a column family in the schema path of the hbase table or whether the schema path is the row key column.

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseUtils

public HBaseUtils()

Method Detail

getBytes

public static byte[] getBytes(String str)

serializeFilter

public static byte[] serializeFilter(org.apache.hadoop.hbase.filter.Filter filter)

deserializeFilter

public static org.apache.hadoop.hbase.filter.Filter deserializeFilter(byte[] filterBytes)

andFilterAtIndex

public static org.apache.hadoop.hbase.filter.Filter andFilterAtIndex(org.apache.hadoop.hbase.filter.Filter currentFilter,
                                                                     int index,
                                                                     org.apache.hadoop.hbase.filter.Filter newFilter)

orFilterAtIndex

public static org.apache.hadoop.hbase.filter.Filter orFilterAtIndex(org.apache.hadoop.hbase.filter.Filter currentFilter,
                                                                    int index,
                                                                    org.apache.hadoop.hbase.filter.Filter newFilter)

maxOfStartRows

public static byte[] maxOfStartRows(byte[] left,
                                    byte[] right)

minOfStartRows

public static byte[] minOfStartRows(byte[] left,
                                    byte[] right)

maxOfStopRows

public static byte[] maxOfStopRows(byte[] left,
                                   byte[] right)

minOfStopRows

public static byte[] minOfStopRows(byte[] left,
                                   byte[] right)

verifyColumns

public static void verifyColumns(List<SchemaPath> columns,
                                 org.apache.hadoop.hbase.HTableDescriptor hTableDesc)

Verify the presence of a column family in the schema path of the hbase table or whether the schema path is the row key column.

Parameters:

columns - List of the selected columns

hTableDesc - HTableDescriptor of HBase/MapR-DB_binary table (consists the details about that table)

Throws:

DrillRuntimeException - if column family does not exist, or is not row_key column.