oracle.spatial.hadoop.vector.binning

Class BinningCommonReducer

java.lang.Object

oracle.spatial.hadoop.vector.binning.BinningCommonReducer

All Implemented Interfaces:

oracle.spatial.hadoop.vector.common.CommonReducer<org.apache.hadoop.io.LongWritable,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

public class BinningCommonReducer
extends java.lang.Object
implements oracle.spatial.hadoop.vector.common.CommonReducer<org.apache.hadoop.io.LongWritable,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

Processes reduce groups containing records mapped to a bin.

Constructor Summary

Constructors

Constructor and Description
BinningCommonReducer()

Method Summary

Modifier and Type	Method and Description
protected void	genCellOutValue(long cellId, long memberCount, oracle.spatial.geometry.JGeometry cellGeom, java.util.Map<java.lang.String,java.lang.Double> aggrFieldValues, org.apache.hadoop.io.Text outValue)
void	init(oracle.spatial.hadoop.vector.common.CommonContext context)
void	reduce(oracle.spatial.hadoop.vector.common.CommonReducerContext<org.apache.hadoop.io.LongWritable,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> context)

Methods inherited from class java.lang.Object

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

Constructor Detail

BinningCommonReducer

public BinningCommonReducer()

Method Detail

init

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

Specified by:

init in interface oracle.spatial.hadoop.vector.common.CommonReducer<org.apache.hadoop.io.LongWritable,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

reduce

public void reduce(oracle.spatial.hadoop.vector.common.CommonReducerContext<org.apache.hadoop.io.LongWritable,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> context)
            throws java.io.IOException,
                   java.lang.InterruptedException

Specified by:

reduce in interface oracle.spatial.hadoop.vector.common.CommonReducer<org.apache.hadoop.io.LongWritable,RecordInfo,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>

Throws:

java.io.IOException

java.lang.InterruptedException

genCellOutValue

protected void genCellOutValue(long cellId,
                               long memberCount,
                               oracle.spatial.geometry.JGeometry cellGeom,
                               java.util.Map<java.lang.String,java.lang.Double> aggrFieldValues,
                               org.apache.hadoop.io.Text outValue)