oracle.spatial.hadoop.vector.binning

Class BinningCommonMapper<K,V>

java.lang.Object

oracle.spatial.hadoop.vector.binning.BinningCommonMapper<K,V>

Type Parameters:

K - The type of the input keys

V - The type of the input values

All Implemented Interfaces:

oracle.spatial.hadoop.vector.common.CommonMapper<oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>,K,V,org.apache.hadoop.io.LongWritable,RecordInfo>, oracle.spatial.hadoop.vector.common.RecordManagedMapper<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

public class BinningCommonMapper<K,V>
extends java.lang.Object
implements oracle.spatial.hadoop.vector.common.RecordManagedMapper<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

Maps input records to bins.

Constructor Summary

Constructors

Constructor and Description
BinningCommonMapper()

Method Summary

Methods

Modifier and Type	Method and Description
void	init(oracle.spatial.hadoop.vector.common.CommonContext context)
void	map(oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K,V,org.apache.hadoop.io.LongWritable,RecordInfo> context)

Methods inherited from class java.lang.Object

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

Constructor Detail

BinningCommonMapper

public BinningCommonMapper()

Method Detail

init

public void init(oracle.spatial.hadoop.vector.common.CommonContext context)

Specified by:

init in interface oracle.spatial.hadoop.vector.common.CommonMapper<oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>,K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

map

public void map(oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K,V,org.apache.hadoop.io.LongWritable,RecordInfo> context)
         throws java.io.IOException,
                java.lang.InterruptedException

Specified by:

map in interface oracle.spatial.hadoop.vector.common.CommonMapper<oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K,V,org.apache.hadoop.io.LongWritable,RecordInfo>,K,V,org.apache.hadoop.io.LongWritable,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException