oracle.spatial.hadoop.vector.cluster.kmeans

Class KMeansCommonReducer

java.lang.Object

oracle.spatial.hadoop.vector.cluster.kmeans.KMeansCommonReducer

All Implemented Interfaces:

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

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

Processes reduce groups which are composed of records mapped to a cluster.
For each group, it updates a cluster center based on its members locations, determines if the cluster center converges and emits the updated cluster information.

Constructor Summary

Constructors

Constructor and Description
KMeansCommonReducer()

Method Summary

Methods

Modifier and Type	Method and Description
void	init(oracle.spatial.hadoop.vector.common.CommonContext context)
void	reduce(oracle.spatial.hadoop.vector.common.CommonReducerContext<ClusterInfo,RecordInfo,ClusterInfo,org.apache.hadoop.io.NullWritable> context)

Methods inherited from class java.lang.Object

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

Constructor Detail

KMeansCommonReducer

public KMeansCommonReducer()

Method Detail

init

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

Specified by:

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

reduce

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

Specified by:

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

Throws:

java.io.IOException

java.lang.InterruptedException