org.apache.hadoop.hive.hbase

Class DefaultHBaseKeyFactory

java.lang.Object

org.apache.hadoop.hive.hbase.AbstractHBaseKeyFactory

org.apache.hadoop.hive.hbase.DefaultHBaseKeyFactory

All Implemented Interfaces:

HBaseKeyFactory, HiveStoragePredicateHandler

Direct Known Subclasses:

CompositeHBaseKeyFactory

public class DefaultHBaseKeyFactory
extends AbstractHBaseKeyFactory
implements HBaseKeyFactory

Nested Class Summary

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

HiveStoragePredicateHandler.DecomposedPredicate

Field Summary

Fields

Modifier and Type	Field and Description
protected LazySerDeParameters	serdeParams
protected HBaseRowSerializer	serializer

Fields inherited from class org.apache.hadoop.hive.hbase.AbstractHBaseKeyFactory

hbaseParams, keyMapping, properties

Constructor Summary

Constructors

Constructor and Description
DefaultHBaseKeyFactory()

Method Summary

Modifier and Type	Method and Description
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 class org.apache.hadoop.hive.hbase.AbstractHBaseKeyFactory

configureJobConf, decomposePredicate

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hive.hbase.HBaseKeyFactory

configureJobConf

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

decomposePredicate

Field Detail

serdeParams

protected LazySerDeParameters serdeParams

serializer

protected HBaseRowSerializer serializer

Constructor Detail

DefaultHBaseKeyFactory

public DefaultHBaseKeyFactory()

Method Detail

init

public void init(HBaseSerDeParameters hbaseParam,
                 Properties properties)
          throws SerDeException

Description copied from interface: HBaseKeyFactory

initialize factory with properties

Specified by:

init in interface HBaseKeyFactory

Overrides:

init in class AbstractHBaseKeyFactory

Throws:

SerDeException

createKeyObjectInspector

public ObjectInspector createKeyObjectInspector(TypeInfo type)
                                         throws SerDeException

Description copied from interface: HBaseKeyFactory

create custom object inspector for hbase key

Specified by:

createKeyObjectInspector in interface HBaseKeyFactory

Parameters:

type - type information

Throws:

SerDeException

createKey

public LazyObjectBase createKey(ObjectInspector inspector)
                         throws SerDeException

Description copied from interface: HBaseKeyFactory

create custom object for hbase key

Specified by:

createKey in interface HBaseKeyFactory

Parameters:

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

Throws:

SerDeException

serializeKey

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

Description copied from interface: HBaseKeyFactory

serialize hive object in internal format of custom key

Specified by:

serializeKey in interface HBaseKeyFactory

Returns:

true if it's not null

Throws:

IOException