com.cloudera.oryx.app.serving.als.model

Class ALSServingModelManager

java.lang.Object

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

com.cloudera.oryx.app.serving.als.model.ALSServingModelManager

All Implemented Interfaces:

ServingModelManager<String>, Closeable, AutoCloseable

public final class ALSServingModelManager
extends AbstractServingModelManager<String>

A ServingModelManager that manages and provides access to an ALSServingModel for the ALS Serving Layer application.

Constructor Summary

Constructors

Constructor and Description
ALSServingModelManager(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.
ALSServingModel	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

ALSServingModelManager

public ALSServingModelManager(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 ALSServingModel getModel()

Returns:

in-memory model representation