org.apache.hadoop.hive.accumulo.serde

Class CompositeAccumuloRowIdFactory<T extends AccumuloCompositeRowId>

java.lang.Object

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

org.apache.hadoop.hive.accumulo.serde.CompositeAccumuloRowIdFactory<T>

Type Parameters:

T -

All Implemented Interfaces:

AccumuloRowIdFactory

public class CompositeAccumuloRowIdFactory<T extends AccumuloCompositeRowId>
extends DefaultAccumuloRowIdFactory

AccumuloRowIdFactory designed for injection of the AccumuloCompositeRowId to be used to generate the Accumulo rowId. Allows for custom AccumuloCompositeRowIds to be specified without overriding the entire ObjectInspector for the Hive row.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.log4j.Logger	log

Fields inherited from class org.apache.hadoop.hive.accumulo.serde.DefaultAccumuloRowIdFactory

accumuloSerDeParams, properties, rowIdMapping, serdeParams, serializer

Constructor Summary

Constructors

Constructor and Description
CompositeAccumuloRowIdFactory(Class<T> keyClass)

Method Summary

Methods

Modifier and Type	Method and Description
void	addDependencyJars(org.apache.hadoop.conf.Configuration jobConf) Add this implementation to the classpath for the Job
T	createRowId(ObjectInspector inspector) create custom object for accumulo

Methods inherited from class org.apache.hadoop.hive.accumulo.serde.DefaultAccumuloRowIdFactory

createRowIdObjectInspector, init, serializeRowId

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final org.apache.log4j.Logger log

Constructor Detail

CompositeAccumuloRowIdFactory

public CompositeAccumuloRowIdFactory(Class<T> keyClass)
                              throws SecurityException,
                                     NoSuchMethodException

Throws:

SecurityException

NoSuchMethodException

Method Detail

addDependencyJars

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

Description copied from interface: AccumuloRowIdFactory

Add this implementation to the classpath for the Job

Specified by:

addDependencyJars in interface AccumuloRowIdFactory

Overrides:

addDependencyJars in class DefaultAccumuloRowIdFactory

Throws:

IOException

createRowId

public T createRowId(ObjectInspector inspector)
                                             throws SerDeException

Description copied from interface: AccumuloRowIdFactory

create custom object for accumulo

Specified by:

createRowId in interface AccumuloRowIdFactory

Overrides:

createRowId in class DefaultAccumuloRowIdFactory

Parameters:

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

Throws:

SerDeException