K
- type of key read from input topicM
- type of message read from input topicU
- type of update message read/writtenpublic final class ScalaSpeedModelManagerAdapter<K,M,U> extends Object implements SpeedModelManager<K,M,U>
ScalaSpeedModelManager
to be a Java SpeedModelManager
.Constructor and Description |
---|
ScalaSpeedModelManagerAdapter(ScalaSpeedModelManager<K,M,U> scalaManager) |
Modifier and Type | Method and Description |
---|---|
Iterable<U> |
buildUpdates(org.apache.spark.api.java.JavaPairRDD<K,M> newData) |
void |
close() |
void |
consume(Iterator<KeyMessage<String,U>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
public ScalaSpeedModelManagerAdapter(ScalaSpeedModelManager<K,M,U> scalaManager)
public void consume(Iterator<KeyMessage<String,U>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf)
consume
in interface SpeedModelManager<K,M,U>
public Iterable<U> buildUpdates(org.apache.spark.api.java.JavaPairRDD<K,M> newData)
buildUpdates
in interface SpeedModelManager<K,M,U>
public void close()
close
in interface SpeedModelManager<K,M,U>
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2014–2015. All rights reserved.