com.cloudera.oryx.app.speed.kmeans

Class KMeansSpeedModelManager

java.lang.Object

com.cloudera.oryx.api.speed.AbstractSpeedModelManager<String,String,String>

com.cloudera.oryx.app.speed.kmeans.KMeansSpeedModelManager

All Implemented Interfaces:

SpeedModelManager<String,String,String>, Closeable, AutoCloseable

public final class KMeansSpeedModelManager
extends AbstractSpeedModelManager<String,String,String>

Implementation of SpeedModelManager that maintains and updates an k-means clustering model in memory.

Constructor Summary

Constructors

Constructor and Description
KMeansSpeedModelManager(com.typesafe.config.Config config)

Method Summary

Modifier and Type	Method and Description
Iterable<String>	buildUpdates(org.apache.spark.api.java.JavaPairRDD<String,String> newData)
void	consumeKeyMessage(String key, String message, org.apache.hadoop.conf.Configuration hadoopConf)

Methods inherited from class com.cloudera.oryx.api.speed.AbstractSpeedModelManager

consume

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.cloudera.oryx.api.speed.SpeedModelManager

close

Constructor Detail

KMeansSpeedModelManager

public KMeansSpeedModelManager(com.typesafe.config.Config config)

Method Detail

consumeKeyMessage

public void consumeKeyMessage(String key,
                              String message,
                              org.apache.hadoop.conf.Configuration hadoopConf)
                       throws IOException

Overrides:

consumeKeyMessage in class AbstractSpeedModelManager<String,String,String>

Throws:

IOException

buildUpdates

public Iterable<String> buildUpdates(org.apache.spark.api.java.JavaPairRDD<String,String> newData)