public final class KMeansServingModelManager extends AbstractServingModelManager<String>
ServingModelManager
that manages and provides access to an
KMeansServingModel
for the k-means Serving Layer application.Constructor and Description |
---|
KMeansServingModelManager(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.
|
KMeansServingModel |
getModel() |
getConfig, isReadOnly
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public KMeansServingModelManager(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 KMeansServingModel getModel()
Copyright © 2014–2016. All rights reserved.