org.apache.hadoop.hive.hbase.struct

Interface HBaseValueFactory

All Known Implementing Classes:

AvroHBaseValueFactory, DefaultHBaseValueFactory, StructHBaseValueFactory

public interface HBaseValueFactory

Provides capability to plugin custom implementations for querying of data stored in HBase.

Method Summary

Modifier and Type	Method and Description
LazyObjectBase	createValueObject(ObjectInspector inspector) create custom object for hbase value
ObjectInspector	createValueObjectInspector(TypeInfo type) create custom object inspector for the value
void	init(HBaseSerDeParameters hbaseParam, org.apache.hadoop.conf.Configuration conf, Properties properties) Initialize factory with properties
byte[]	serializeValue(Object object, StructField field) Serialize the given hive object

Method Detail

init

void init(HBaseSerDeParameters hbaseParam,
          org.apache.hadoop.conf.Configuration conf,
          Properties properties)
   throws SerDeException

Initialize factory with properties

Parameters:

hbaseParam - the hbase parameters

conf - the hadoop configuration

properties - the custom Properties

Throws:

SerDeException - if there was an issue initializing the factory

createValueObjectInspector

ObjectInspector createValueObjectInspector(TypeInfo type)
                                    throws SerDeException

create custom object inspector for the value

Parameters:

type - type information

Throws:

SerDeException - if there was an issue creating the object inspector

createValueObject

LazyObjectBase createValueObject(ObjectInspector inspector)
                          throws SerDeException

create custom object for hbase value

Parameters:

inspector - OI create by HBaseKeyFactory.createKeyObjectInspector(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo)

Throws:

SerDeException

serializeValue

byte[] serializeValue(Object object,
                      StructField field)
               throws IOException

Serialize the given hive object

Parameters:

object - the object to be serialized

field - the StructField

Returns:

the serialized value

Throws:

{@link - IOException} if there was an issue serializing the value

IOException