com.cloudera.oryx.app.serving.kmeans.model

Class KMeansServingModelManager

java.lang.Object

com.cloudera.oryx.api.serving.AbstractServingModelManager<String>

com.cloudera.oryx.app.serving.kmeans.model.KMeansServingModelManager

All Implemented Interfaces:

ServingModelManager<String>, Closeable, AutoCloseable

public final class KMeansServingModelManager
extends AbstractServingModelManager<String>

A ServingModelManager that manages and provides access to an KMeansServingModel for the k-means Serving Layer application.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	consumeKeyMessage(String key, String message, org.apache.hadoop.conf.Configuration hadoopConf) Convenience method that is called by the default implementation of AbstractServingModelManager.consume(Iterator, Configuration), to process one key-message pair.
KMeansServingModel	getModel()

Methods inherited from class com.cloudera.oryx.api.serving.AbstractServingModelManager

consume, getConfig, isReadOnly

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.serving.ServingModelManager

close

Constructor Detail

KMeansServingModelManager

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

Method Detail

consumeKeyMessage

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

Description copied from class: AbstractServingModelManager

Convenience method that is called by the default implementation of AbstractServingModelManager.consume(Iterator, Configuration), to process one key-message pair. It does nothing, except log the message. This should generally be overridden if and only if AbstractServingModelManager.consume(Iterator, Configuration) is not.

Overrides:

consumeKeyMessage in class AbstractServingModelManager<String>

Parameters:

key - key to process (non-null)

message - message to process

hadoopConf - Hadoop configuration for process

Throws:

IOException - if an error occurs while processing the message

getModel

public KMeansServingModel getModel()

Returns:

in-memory model representation