org.locationtech.geowave.analytic.mapreduce.nn

Class NNMapReduce.NNSimpleFeatureIDOutputReducer

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<NNMapReduce.PartitionDataWritable,AdapterWithObjectWritable,KEYOUT,VALUEOUT>

org.locationtech.geowave.analytic.mapreduce.nn.NNMapReduce.NNReducer<org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,Boolean>

org.locationtech.geowave.analytic.mapreduce.nn.NNMapReduce.NNSimpleFeatureIDOutputReducer

Enclosing class:

NNMapReduce

public static class NNMapReduce.NNSimpleFeatureIDOutputReducer
extends NNMapReduce.NNReducer<org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,Boolean>

Nested Class Summary

Nested classes/interfaces inherited from class org.locationtech.geowave.analytic.mapreduce.nn.NNMapReduce.NNReducer

NNMapReduce.NNReducer.LocalDistanceProfileGenerateFn

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

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

Fields inherited from class org.locationtech.geowave.analytic.mapreduce.nn.NNMapReduce.NNReducer

distanceFn, distanceProfileFn, maxDistance, maxNeighbors, partitioner, serializationTool, typeConverter

Constructor Summary

Constructors

Constructor and Description
NNSimpleFeatureIDOutputReducer()

Method Summary

Modifier and Type	Method and Description
protected Boolean	createSummary()
protected void	processNeighbors(Partitioner.PartitionData partitionData, ByteArray primaryId, org.opengis.feature.simple.SimpleFeature primary, NeighborList<org.opengis.feature.simple.SimpleFeature> neighbors, org.apache.hadoop.mapreduce.Reducer.Context context, Boolean summary)
protected void	processSummary(Partitioner.PartitionData partitionData, Boolean summary, org.apache.hadoop.mapreduce.Reducer.Context context) Allow extended classes to do some final processing for the partition.

Methods inherited from class org.locationtech.geowave.analytic.mapreduce.nn.NNMapReduce.NNReducer

createNeighborsListFactory, createSetForNeighbors, preprocess, reduce, setup

Methods inherited from class org.apache.hadoop.mapreduce.Reducer

cleanup, run

Methods inherited from class java.lang.Object

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

Constructor Detail

NNSimpleFeatureIDOutputReducer

public NNSimpleFeatureIDOutputReducer()

Method Detail

processNeighbors

protected void processNeighbors(Partitioner.PartitionData partitionData,
                                ByteArray primaryId,
                                org.opengis.feature.simple.SimpleFeature primary,
                                NeighborList<org.opengis.feature.simple.SimpleFeature> neighbors,
                                org.apache.hadoop.mapreduce.Reducer.Context context,
                                Boolean summary)
                         throws IOException,
                                InterruptedException

Specified by:

processNeighbors in class NNMapReduce.NNReducer<org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,Boolean>

Throws:

IOException

InterruptedException

createSummary

protected Boolean createSummary()

Specified by:

createSummary in class NNMapReduce.NNReducer<org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,Boolean>

Returns:

an object that represents a summary of the neighbors processed

processSummary

protected void processSummary(Partitioner.PartitionData partitionData,
                              Boolean summary,
                              org.apache.hadoop.mapreduce.Reducer.Context context)

Description copied from class: NNMapReduce.NNReducer

Allow extended classes to do some final processing for the partition.

Specified by:

processSummary in class NNMapReduce.NNReducer<org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,Boolean>