org.locationtech.geowave.mapreduce.dedupe

Class GeoWaveDedupeMapper

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.dedupe.GeoWaveDedupeMapper

public class GeoWaveDedupeMapper
extends GeoWaveWritableOutputMapper<GeoWaveInputKey,Object>

Basically an identity mapper used for the deduplication 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
GeoWaveDedupeMapper()

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

GeoWaveDedupeMapper

public GeoWaveDedupeMapper()

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