oracle.spatial.hadoop.vector.cluster.kmeans

Class KMeansCommonMapper<K_IN,V_IN>

java.lang.Object

oracle.spatial.hadoop.vector.cluster.kmeans.KMeansCommonMapper<K_IN,V_IN>

Type Parameters:

K_IN - The type of the input keys

V_IN - The type of the input values

All Implemented Interfaces:

oracle.spatial.hadoop.vector.common.CommonMapper<oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K_IN,V_IN,ClusterInfo,RecordInfo>,K_IN,V_IN,ClusterInfo,RecordInfo>, oracle.spatial.hadoop.vector.common.RecordManagedMapper<K_IN,V_IN,ClusterInfo,RecordInfo>

public class KMeansCommonMapper<K_IN,V_IN>
extends java.lang.Object
implements oracle.spatial.hadoop.vector.common.RecordManagedMapper<K_IN,V_IN,ClusterInfo,RecordInfo>

Maps each input record to its closest cluster center.

Constructor Summary

Constructors

Constructor and Description
KMeansCommonMapper()

Method Summary

Methods

Modifier and Type	Method and Description
void	init(oracle.spatial.hadoop.vector.common.CommonContext context)
void	map(oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K_IN,V_IN,ClusterInfo,RecordInfo> context)

Methods inherited from class java.lang.Object

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

Constructor Detail

KMeansCommonMapper

public KMeansCommonMapper()

Method Detail

init

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

Specified by:

init in interface oracle.spatial.hadoop.vector.common.CommonMapper<oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K_IN,V_IN,ClusterInfo,RecordInfo>,K_IN,V_IN,ClusterInfo,RecordInfo>

map

public void map(oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K_IN,V_IN,ClusterInfo,RecordInfo> context)
         throws java.io.IOException,
                java.lang.InterruptedException

Specified by:

map in interface oracle.spatial.hadoop.vector.common.CommonMapper<oracle.spatial.hadoop.vector.common.RecordManagedMapperContext<K_IN,V_IN,ClusterInfo,RecordInfo>,K_IN,V_IN,ClusterInfo,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException