public final class ExampleServingModelManager extends AbstractServingModelManager<String>
Constructor and Description |
---|
ExampleServingModelManager(com.typesafe.config.Config config) |
Modifier and Type | Method and Description |
---|---|
void |
consume(Iterator<KeyMessage<String,String>> 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.
|
ServingModel |
getModel() |
getConfig, isReadOnly
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public ExampleServingModelManager(com.typesafe.config.Config config)
public void consume(Iterator<KeyMessage<String,String>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf) throws IOException
ServingModelManager
updateIterator
- iterator to read models fromhadoopConf
- Hadoop context, which may be required for reading from HDFSIOException
- if an error occurs while reading updatespublic ServingModel getModel()
Copyright © 2014–2016. All rights reserved.