org.apache.hadoop.hive.accumulo.serde

Class DefaultAccumuloRowIdFactory

java.lang.Object

org.apache.hadoop.hive.accumulo.serde.DefaultAccumuloRowIdFactory

All Implemented Interfaces:

AccumuloRowIdFactory

Direct Known Subclasses:

CompositeAccumuloRowIdFactory

public class DefaultAccumuloRowIdFactory
extends Object
implements AccumuloRowIdFactory

Default implementation of the AccumuloRowIdFactory which uses the normal AccumuloRowSerializer methods to serialize the field for storage into Accumulo.

Field Summary

Fields

Modifier and Type	Field and Description
protected AccumuloSerDeParameters	accumuloSerDeParams
protected Properties	properties
protected HiveAccumuloRowIdColumnMapping	rowIdMapping
protected LazySerDeParameters	serdeParams
protected AccumuloRowSerializer	serializer

Constructor Summary

Constructors

Constructor and Description
DefaultAccumuloRowIdFactory()

Method Summary

Methods

Modifier and Type	Method and Description
void	addDependencyJars(org.apache.hadoop.conf.Configuration conf) Add this implementation to the classpath for the Job
LazyObjectBase	createRowId(ObjectInspector inspector) create custom object for accumulo
ObjectInspector	createRowIdObjectInspector(TypeInfo type) create custom object inspector for accumulo rowId
void	init(AccumuloSerDeParameters accumuloSerDeParams, Properties properties) initialize factory with properties
byte[]	serializeRowId(Object object, StructField field, ByteStream.Output output) serialize hive object in internal format of custom key

Methods inherited from class java.lang.Object

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

Field Detail

accumuloSerDeParams

protected AccumuloSerDeParameters accumuloSerDeParams

serdeParams

protected LazySerDeParameters serdeParams

properties

protected Properties properties

rowIdMapping

protected HiveAccumuloRowIdColumnMapping rowIdMapping

serializer

protected AccumuloRowSerializer serializer

Constructor Detail

DefaultAccumuloRowIdFactory

public DefaultAccumuloRowIdFactory()

Method Detail

init

public void init(AccumuloSerDeParameters accumuloSerDeParams,
        Properties properties)
          throws SerDeException

Description copied from interface: AccumuloRowIdFactory

initialize factory with properties

Specified by:

init in interface AccumuloRowIdFactory

Throws:

SerDeException

addDependencyJars

public void addDependencyJars(org.apache.hadoop.conf.Configuration conf)
                       throws IOException

Description copied from interface: AccumuloRowIdFactory

Add this implementation to the classpath for the Job

Specified by:

addDependencyJars in interface AccumuloRowIdFactory

Throws:

IOException

createRowIdObjectInspector

public ObjectInspector createRowIdObjectInspector(TypeInfo type)
                                           throws SerDeException

Description copied from interface: AccumuloRowIdFactory

create custom object inspector for accumulo rowId

Specified by:

createRowIdObjectInspector in interface AccumuloRowIdFactory

Parameters:

type - type information

Throws:

SerDeException

createRowId

public LazyObjectBase createRowId(ObjectInspector inspector)
                           throws SerDeException

Description copied from interface: AccumuloRowIdFactory

create custom object for accumulo

Specified by:

createRowId in interface AccumuloRowIdFactory

Parameters:

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

Throws:

SerDeException

serializeRowId

public byte[] serializeRowId(Object object,
                    StructField field,
                    ByteStream.Output output)
                      throws IOException

Description copied from interface: AccumuloRowIdFactory

serialize hive object in internal format of custom key

Specified by:

serializeRowId in interface AccumuloRowIdFactory

Throws:

IOException