org.apache.hadoop.hive.hbase

Interface HBaseKeyFactory

All Superinterfaces:

HiveStoragePredicateHandler

All Known Implementing Classes:

AbstractHBaseKeyFactory, CompositeHBaseKeyFactory, DefaultHBaseKeyFactory

public interface HBaseKeyFactory
extends HiveStoragePredicateHandler

Provides custom implementation of object and object inspector for hbase key. The key object should implement LazyObjectBase. User can optionally implement HiveStoragePredicateHandler for handling filter predicates

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler

HiveStoragePredicateHandler.DecomposedPredicate

Method Summary

Methods

Modifier and Type	Method and Description
void	configureJobConf(TableDesc tableDesc, org.apache.hadoop.mapred.JobConf jobConf) configure jobConf for this factory
LazyObjectBase	createKey(ObjectInspector inspector) create custom object for hbase key
ObjectInspector	createKeyObjectInspector(TypeInfo type) create custom object inspector for hbase key
void	init(HBaseSerDeParameters hbaseParam, Properties properties) initialize factory with properties
byte[]	serializeKey(Object object, StructField field) serialize hive object in internal format of custom key

Methods inherited from interface org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler

decomposePredicate

Method Detail

init

void init(HBaseSerDeParameters hbaseParam,
        Properties properties)
          throws SerDeException

initialize factory with properties

Throws:

SerDeException

createKeyObjectInspector

ObjectInspector createKeyObjectInspector(TypeInfo type)
                                         throws SerDeException

create custom object inspector for hbase key

Parameters:

type - type information

Throws:

SerDeException

createKey

LazyObjectBase createKey(ObjectInspector inspector)
                         throws SerDeException

create custom object for hbase key

Parameters:

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

Throws:

SerDeException

serializeKey

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

serialize hive object in internal format of custom key

Parameters:

object -

field -

Returns:

true if it's not null

Throws:

IOException

configureJobConf

void configureJobConf(TableDesc tableDesc,
                    org.apache.hadoop.mapred.JobConf jobConf)
                      throws IOException

configure jobConf for this factory

Parameters:

tableDesc -

jobConf -

Throws:

IOException