com.cloudera.oryx.lambda.serving

Class ScalaServingModelManagerAdapter<U>

java.lang.Object

com.cloudera.oryx.lambda.serving.ScalaServingModelManagerAdapter<U>

Type Parameters:

U - type of update message read/written

All Implemented Interfaces:

ServingModelManager<U>, Closeable, AutoCloseable

public final class ScalaServingModelManagerAdapter<U>
extends Object
implements ServingModelManager<U>

Adapts a ScalaServingModelManager to be a Java ServingModelManager.

Constructor Summary

Constructors

Constructor and Description
ScalaServingModelManagerAdapter(com.cloudera.oryx.api.serving.ScalaServingModelManager<U> scalaManager)

Method Summary

Modifier and Type	Method and Description
void	close()
void	consume(Iterator<KeyMessage<String,U>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf) Called by the framework to initiate a continuous process of reading models, and reading from the input topic and updating model state in memory, and issuing updates to the update topic.
com.typesafe.config.Config	getConfig()
ServingModel	getModel()
boolean	isReadOnly()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalaServingModelManagerAdapter

public ScalaServingModelManagerAdapter(com.cloudera.oryx.api.serving.ScalaServingModelManager<U> scalaManager)

Method Detail

consume

public void consume(Iterator<KeyMessage<String,U>> updateIterator,
                    org.apache.hadoop.conf.Configuration hadoopConf)

Description copied from interface: ServingModelManager

Called by the framework to initiate a continuous process of reading models, and reading from the input topic and updating model state in memory, and issuing updates to the update topic. This will be executed asynchronously and may block. Note that an exception or error thrown from this method is fatal and shuts down processing.

Specified by:

consume in interface ServingModelManager<U>

Parameters:

updateIterator - iterator to read models from

hadoopConf - Hadoop context, which may be required for reading from HDFS

getConfig

public com.typesafe.config.Config getConfig()

Specified by:

getConfig in interface ServingModelManager<U>

Returns:

configuration for the serving layer

getModel

public ServingModel getModel()

Specified by:

getModel in interface ServingModelManager<U>

Returns:

in-memory model representation

isReadOnly

public boolean isReadOnly()

Specified by:

isReadOnly in interface ServingModelManager<U>

Returns:

true iff the model is considered read-only and not updateable

close

public void close()

Specified by:

close in interface ServingModelManager<U>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable