org.locationtech.geowave.mapreduce.copy

Class StoreCopyMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,GeoWaveInputKey,org.apache.hadoop.io.ObjectWritable>

org.locationtech.geowave.mapreduce.GeoWaveWritableOutputMapper<GeoWaveInputKey,Object>

org.locationtech.geowave.mapreduce.copy.StoreCopyMapper

public class StoreCopyMapper
extends GeoWaveWritableOutputMapper<GeoWaveInputKey,Object>

Basically an identity mapper used for the copy job

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

Fields inherited from class org.locationtech.geowave.mapreduce.GeoWaveWritableOutputMapper

LOGGER, serializationTool

Constructor Summary

Constructors

Constructor and Description
StoreCopyMapper()

Method Summary

Modifier and Type	Method and Description
protected void	mapNativeValue(GeoWaveInputKey key, Object value, org.apache.hadoop.mapreduce.MapContext<GeoWaveInputKey,Object,GeoWaveInputKey,Object> context)

Methods inherited from class org.locationtech.geowave.mapreduce.GeoWaveWritableOutputMapper

map, mapWritableValue, setup

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

cleanup, run

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreCopyMapper

public StoreCopyMapper()

Method Detail

mapNativeValue

protected void mapNativeValue(GeoWaveInputKey key,
                              Object value,
                              org.apache.hadoop.mapreduce.MapContext<GeoWaveInputKey,Object,GeoWaveInputKey,Object> context)
                       throws IOException,
                              InterruptedException

Specified by:

mapNativeValue in class GeoWaveWritableOutputMapper<GeoWaveInputKey,Object>

Throws:

IOException

InterruptedException