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

Class ClusterMembershipMapper<K,V>

java.lang.Object

org.apache.hadoop.mapred.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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<K,V,ClusterInfo,RecordInfo>

public class ClusterMembershipMapper<K,V>
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.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.

Constructor Summary

Constructors

Constructor and Description
ClusterMembershipMapper()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf jobConf)
void	map(K key, V value, org.apache.hadoop.mapred.OutputCollector<ClusterInfo,RecordInfo> output, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.hadoop.mapred.MapReduceBase

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

ClusterMembershipMapper

public ClusterMembershipMapper()

Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf jobConf)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

Overrides:

configure in class org.apache.hadoop.mapred.MapReduceBase

map

public void map(K key,
       V value,
       org.apache.hadoop.mapred.OutputCollector<ClusterInfo,RecordInfo> output,
       org.apache.hadoop.mapred.Reporter reporter)
         throws java.io.IOException

Specified by:

map in interface org.apache.hadoop.mapred.Mapper<K,V,ClusterInfo,RecordInfo>

Throws:

java.io.IOException