K
- type of key read from input topicM
- type of message read from input topicU
- type of model message writtenpublic final class ScalaBatchLayerUpdateAdapter<K,M,U> extends Object implements BatchLayerUpdate<K,M,U>
ScalaBatchLayerUpdate
to be a Java BatchLayerUpdate
.Constructor and Description |
---|
ScalaBatchLayerUpdateAdapter(ScalaBatchLayerUpdate<K,M,U> scalaUpdate) |
Modifier and Type | Method and Description |
---|---|
void |
runUpdate(org.apache.spark.api.java.JavaSparkContext sparkContext,
long timestamp,
org.apache.spark.api.java.JavaPairRDD<K,M> newData,
org.apache.spark.api.java.JavaPairRDD<K,M> pastData,
String modelDirString,
TopicProducer<String,U> modelUpdateTopic) |
public ScalaBatchLayerUpdateAdapter(ScalaBatchLayerUpdate<K,M,U> scalaUpdate)
public void runUpdate(org.apache.spark.api.java.JavaSparkContext sparkContext, long timestamp, org.apache.spark.api.java.JavaPairRDD<K,M> newData, org.apache.spark.api.java.JavaPairRDD<K,M> pastData, String modelDirString, TopicProducer<String,U> modelUpdateTopic)
runUpdate
in interface BatchLayerUpdate<K,M,U>
Copyright © 2014–2015. All rights reserved.