oracle.spatial.hadoop.vector.binning.mapred

Class BinMapper<K,V>

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

oracle.spatial.hadoop.vector.binning.mapred.BinMapper<K,V>

Type Parameters:

K - The type of the input keys

V - The type of the input values

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

public class BinMapper<K,V>
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Mapper<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

A subclass of Mapper that maps input records to bins. The emitted key is the bin identifier and the value is a RecordInfo containing the input record information. BinningConfig information is expected to be found in the job configuration.

Constructor Summary

Constructors

Constructor and Description
BinMapper()

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf jobConf)
void	map(K key, V value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.LongWritable,RecordInfo> output, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.hadoop.mapred.MapReduceBase

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

BinMapper

public BinMapper()

Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf jobConf)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

Overrides:

configure in class org.apache.hadoop.mapred.MapReduceBase

map

public void map(K key,
                V value,
                org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.LongWritable,RecordInfo> output,
                org.apache.hadoop.mapred.Reporter reporter)
         throws java.io.IOException

Specified by:

map in interface org.apache.hadoop.mapred.Mapper<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

Throws:

java.io.IOException