Package 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
    Description
    HBaseUtils()
     

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • HBaseUtils

      public HBaseUtils()

  • Method Details

    • 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.