oracle.spatial.hadoop.vector.partition.mapreduce

Class HilbertValueMapper

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit,HilbertValueGroup,RecordInfo>

oracle.spatial.hadoop.vector.partition.mapreduce.HilbertValueMapper

public class HilbertValueMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit,HilbertValueGroup,RecordInfo>

Calculates a hilbert value for every point of each input record geometry. The hilbert value is emitted along with the input record as a RecordInfo value. The emitted key contains a fixed group id so can be grouped in one single group.

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
HilbertValueMapper()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	map(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.mapreduce.InputSplit value, org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context context)

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

HilbertValueMapper

public HilbertValueMapper()

Method Detail

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
              throws java.io.IOException,
                     java.lang.InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit,HilbertValueGroup,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException

map

protected void map(org.apache.hadoop.io.NullWritable key,
                   org.apache.hadoop.mapreduce.InputSplit value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapreduce.InputSplit,HilbertValueGroup,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException