edu.iu.dsc.tws.examples.batch.kmeans

Class KMeansComputeJob.CentroidAggregator

java.lang.Object

edu.iu.dsc.tws.examples.batch.kmeans.KMeansComputeJob.CentroidAggregator

All Implemented Interfaces:

IFunction, java.io.Serializable

Enclosing class:

KMeansComputeJob

public static class KMeansComputeJob.CentroidAggregator
extends java.lang.Object
implements IFunction

This class aggregates the cluster centroid values and sum the new centroid values.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CentroidAggregator()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	onMessage(java.lang.Object object1, java.lang.Object object2) The actual message callback

Methods inherited from class java.lang.Object

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

Constructor Detail

CentroidAggregator

public CentroidAggregator()

Method Detail

onMessage

public java.lang.Object onMessage(java.lang.Object object1,
                                  java.lang.Object object2)
                           throws java.lang.ArrayIndexOutOfBoundsException

The actual message callback

Specified by:

onMessage in interface IFunction

Parameters:

object1 - the actual message

object2 - the actual message

Throws:

java.lang.ArrayIndexOutOfBoundsException