oracle.spatial.hadoop.vector.cluster.kmeans.mapreduce

Class KMeansMapper<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<K,V,ClusterInfo,RecordInfo>

oracle.spatial.hadoop.vector.cluster.kmeans.mapreduce.KMeansMapper<K,V>

Type Parameters:

K - The type of the input keys

V - The type of the input values

public class KMeansMapper<K,V>
extends org.apache.hadoop.mapreduce.Mapper<K,V,ClusterInfo,RecordInfo>

A subclass of Mapper that maps each input record to its closest cluster center.
Emitted key and value are a ClusterInfo instance containing the cluster information and a RecordInfo instance containing the information of the record mapped to the cluster. Mapper in charge of assigning each input record to its closest cluster center.

Nested Class Summary

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

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
KMeansMapper()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	map(K key, V value, org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Mapper.Context context)

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

cleanup, run

Methods inherited from class java.lang.Object

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

Constructor Detail

KMeansMapper

public KMeansMapper()

Method Detail

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
              throws java.io.IOException,
                     java.lang.InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<K,V,ClusterInfo,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException

map

protected void map(K key,
                   V value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws java.io.IOException,
                   java.lang.InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<K,V,ClusterInfo,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException