org.apache.hadoop.hive.hbase.struct

Class DefaultHBaseValueFactory

java.lang.Object

org.apache.hadoop.hive.hbase.struct.DefaultHBaseValueFactory

All Implemented Interfaces:

HBaseValueFactory

Direct Known Subclasses:

AvroHBaseValueFactory, StructHBaseValueFactory

public class DefaultHBaseValueFactory
extends Object
implements HBaseValueFactory

Default implementation of the HBaseValueFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected ColumnMappings	columnMappings
protected org.apache.hadoop.conf.Configuration	conf
protected HBaseSerDeParameters	hbaseParams
protected Properties	properties
protected LazySerDeParameters	serdeParams

Constructor Summary

Constructors

Constructor and Description
DefaultHBaseValueFactory(int fieldID)

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 hbaseParams, org.apache.hadoop.conf.Configuration conf, Properties properties) Initialize factory with properties
byte[]	serializeValue(Object object, StructField field) Serialize the given hive object

Methods inherited from class java.lang.Object

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

Field Detail

serdeParams

protected LazySerDeParameters serdeParams

columnMappings

protected ColumnMappings columnMappings

hbaseParams

protected HBaseSerDeParameters hbaseParams

properties

protected Properties properties

conf

protected org.apache.hadoop.conf.Configuration conf

Constructor Detail

DefaultHBaseValueFactory

public DefaultHBaseValueFactory(int fieldID)

Method Detail

init

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

Description copied from interface: HBaseValueFactory

Initialize factory with properties

Specified by:

init in interface HBaseValueFactory

Parameters:

hbaseParams - the hbase parameters

conf - the hadoop configuration

properties - the custom Properties

Throws:

SerDeException - if there was an issue initializing the factory

createValueObjectInspector

public ObjectInspector createValueObjectInspector(TypeInfo type)
                                           throws SerDeException

Description copied from interface: HBaseValueFactory

create custom object inspector for the value

Specified by:

createValueObjectInspector in interface HBaseValueFactory

Parameters:

type - type information

Throws:

SerDeException - if there was an issue creating the object inspector

createValueObject

public LazyObjectBase createValueObject(ObjectInspector inspector)
                                 throws SerDeException

Description copied from interface: HBaseValueFactory

create custom object for hbase value

Specified by:

createValueObject in interface HBaseValueFactory

Parameters:

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

Throws:

SerDeException

serializeValue

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

Description copied from interface: HBaseValueFactory

Serialize the given hive object

Specified by:

serializeValue in interface HBaseValueFactory

Parameters:

object - the object to be serialized

field - the StructField

Returns:

the serialized value

Throws:

IOException