org.apache.hadoop.hive.accumulo.serde

Interface AccumuloRowIdFactory

All Known Implementing Classes:

CompositeAccumuloRowIdFactory, DefaultAccumuloRowIdFactory

public interface AccumuloRowIdFactory

Interface for providing custom Accumulo RowID generation/parsing

Method Summary

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 serDeParams, Properties properties) initialize factory with properties
byte[]	serializeRowId(Object object, StructField field, ByteStream.Output output) serialize hive object in internal format of custom key

Method Detail

init

void init(AccumuloSerDeParameters serDeParams,
          Properties properties)
   throws SerDeException

initialize factory with properties

Throws:

SerDeException

createRowIdObjectInspector

ObjectInspector createRowIdObjectInspector(TypeInfo type)
                                    throws SerDeException

create custom object inspector for accumulo rowId

Parameters:

type - type information

Throws:

SerDeException

createRowId

LazyObjectBase createRowId(ObjectInspector inspector)
                    throws SerDeException

create custom object for accumulo

Parameters:

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

Throws:

SerDeException

serializeRowId

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

serialize hive object in internal format of custom key

Throws:

IOException

addDependencyJars

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

Add this implementation to the classpath for the Job

Throws:

IOException