oracle.spatial.hadoop.vector.cluster.kmeans.mapred

Class ClusterMembershipMapper<K,V>

java.lang.Object

MapReduceBase

oracle.spatial.hadoop.vector.cluster.kmeans.mapred.ClusterMembershipMapper<K,V>

Type Parameters:

K - The type of the input keys

V - The type of the input values

public class ClusterMembershipMapper<K,V>
extends MapReduceBase

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.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
ClusterMembershipMapper()

Method Summary

Modifier and Type	Method and Description
void	configure(JobConf jobConf)
void	map(K key, V value, <any> output, Reporter reporter)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterMembershipMapper

public ClusterMembershipMapper()

Method Detail

configure

public void configure(JobConf jobConf)

map

public void map(K key,
                V value,
                <any> output,
                Reporter reporter)
         throws java.io.IOException

Throws:

java.io.IOException