org.apache.hadoop.hive.hbase.struct

Class AvroHBaseValueFactory

java.lang.Object

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

org.apache.hadoop.hive.hbase.struct.AvroHBaseValueFactory

All Implemented Interfaces:

HBaseValueFactory

public class AvroHBaseValueFactory
extends DefaultHBaseValueFactory

Avro specific implementation of the HBaseValueFactory

Field Summary

Fields inherited from class org.apache.hadoop.hive.hbase.struct.DefaultHBaseValueFactory

columnMappings, conf, hbaseParams, properties, serdeParams

Constructor Summary

Constructors

Constructor and Description
AvroHBaseValueFactory(int fieldID, org.apache.avro.Schema schema) Constructor

Method Summary

Methods

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

createValueObject

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroHBaseValueFactory

public AvroHBaseValueFactory(int fieldID,
                     org.apache.avro.Schema schema)

Constructor

Parameters:

schema - the associated schema

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

Overrides:

init in class DefaultHBaseValueFactory

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

Overrides:

createValueObjectInspector in class DefaultHBaseValueFactory

Parameters:

type - type information

Throws:

SerDeException - if there was an issue creating the object inspector

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

Overrides:

serializeValue in class DefaultHBaseValueFactory

Parameters:

object - the object to be serialized

field - the StructField

Returns:

the serialized value

Throws:

IOException