org.locationtech.geowave.mapreduce

Class HadoopWritableSerializationTool

java.lang.Object

org.locationtech.geowave.mapreduce.HadoopWritableSerializationTool

public class HadoopWritableSerializationTool
extends Object

Use this class to maintain a set of serializers per adapters associated with the context of a single mapper or reducer. The intent is to support maintaining single set of Writable instances. By the nature of holding single instances of Writable instances by the serializers, this class and its contents may be only accessed by one 'worker' (at a time).

The helper methods assume all Writable instances are wrapped in an ObjectWritable. The reason for this approach, consistent with other support classes in this package, is to allow mappers and reducers to use the generic ObjectWritable since entry inputs maybe be associated with different adapters, and thus have different associated Writable instances. Configuration of Hadoop Mappers and Reducers requires a specific type.

Constructor Summary

Constructors

Constructor and Description
HadoopWritableSerializationTool(org.apache.hadoop.mapreduce.JobContext jobContext)
HadoopWritableSerializationTool(TransientAdapterStore adapterStore, InternalAdapterStore internalAdapterStore)

Method Summary

Modifier and Type	Method and Description
Object	fromWritable(short adapterId, org.apache.hadoop.io.ObjectWritable writable)
Object	fromWritable(String typeName, org.apache.hadoop.io.ObjectWritable writable)
DataTypeAdapter<?>	getAdapter(String typeName)
TransientAdapterStore	getAdapterStore()
HadoopWritableSerializer<Object,org.apache.hadoop.io.Writable>	getHadoopWritableSerializerForAdapter(short adapterId)
HadoopWritableSerializer<Object,org.apache.hadoop.io.Writable>	getHadoopWritableSerializerForAdapter(String typeName)
InternalDataAdapter<?>	getInternalAdapter(short adapterId)
org.apache.hadoop.io.ObjectWritable	toWritable(short adapterId, Object entry)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopWritableSerializationTool

public HadoopWritableSerializationTool(org.apache.hadoop.mapreduce.JobContext jobContext)

HadoopWritableSerializationTool

public HadoopWritableSerializationTool(TransientAdapterStore adapterStore,
                                       InternalAdapterStore internalAdapterStore)

Method Detail

getAdapterStore

public TransientAdapterStore getAdapterStore()

getInternalAdapter

public InternalDataAdapter<?> getInternalAdapter(short adapterId)

getAdapter

public DataTypeAdapter<?> getAdapter(String typeName)

getHadoopWritableSerializerForAdapter

public HadoopWritableSerializer<Object,org.apache.hadoop.io.Writable> getHadoopWritableSerializerForAdapter(short adapterId)

getHadoopWritableSerializerForAdapter

public HadoopWritableSerializer<Object,org.apache.hadoop.io.Writable> getHadoopWritableSerializerForAdapter(String typeName)

toWritable

public org.apache.hadoop.io.ObjectWritable toWritable(short adapterId,
                                                      Object entry)

fromWritable

public Object fromWritable(String typeName,
                           org.apache.hadoop.io.ObjectWritable writable)

fromWritable

public Object fromWritable(short adapterId,
                           org.apache.hadoop.io.ObjectWritable writable)