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