org.apache.hadoop.hive.hbase

Class HBaseSerDeHelper

java.lang.Object

org.apache.hadoop.hive.hbase.HBaseSerDeHelper

public class HBaseSerDeHelper
extends Object

Helper class for HBaseSerDe

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG Logger

Constructor Summary

Constructors

Constructor and Description
HBaseSerDeHelper()

Method Summary

Methods

Modifier and Type	Method and Description
static LazyObjectBase	createLazyField(ColumnMappings.ColumnMapping[] columnMappings, int fieldID, ObjectInspector inspector) Create the lazy field
static void	generateColumns(Properties tbl, List<ColumnMappings.ColumnMapping> columnsMapping, StringBuilder sb) Autogenerates the columns from the given serialization class
static void	generateColumnTypes(Properties tbl, List<ColumnMappings.ColumnMapping> columnsMapping, StringBuilder sb, org.apache.hadoop.conf.Configuration conf) Autogenerates the column types from the given serialization class
static org.apache.avro.Schema	getSchemaFromFS(String schemaFSUrl, org.apache.hadoop.conf.Configuration conf) Read the schema from the given hdfs url for the schema

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

Logger

Constructor Detail

HBaseSerDeHelper

public HBaseSerDeHelper()

Method Detail

generateColumns

public static void generateColumns(Properties tbl,
                   List<ColumnMappings.ColumnMapping> columnsMapping,
                   StringBuilder sb)

Autogenerates the columns from the given serialization class

Parameters:

tbl - the hive table properties

columnsMapping - the hbase columns mapping determining hbase column families and qualifiers

sb - StringBuilder to form the list of columns

Throws:

IllegalArgumentException - if any of the given arguments was null

generateColumnTypes

public static void generateColumnTypes(Properties tbl,
                       List<ColumnMappings.ColumnMapping> columnsMapping,
                       StringBuilder sb,
                       org.apache.hadoop.conf.Configuration conf)
                                throws SerDeException

Autogenerates the column types from the given serialization class

Parameters:

tbl - the hive table properties

columnsMapping - the hbase columns mapping determining hbase column families and qualifiers

sb - StringBuilder to form the list of columns

conf - configuration

Throws:

IllegalArgumentException - if any of the given arguments was null

SerDeException - if there was an error generating the column types

getSchemaFromFS

public static org.apache.avro.Schema getSchemaFromFS(String schemaFSUrl,
                                     org.apache.hadoop.conf.Configuration conf)
                                              throws SerDeException

Read the schema from the given hdfs url for the schema

Throws:

SerDeException

createLazyField

public static LazyObjectBase createLazyField(ColumnMappings.ColumnMapping[] columnMappings,
                             int fieldID,
                             ObjectInspector inspector)

Create the lazy field