- Type Parameters:
K
- type of key read from input topic
M
- type of message read from input topic
U
- type of update message read/written
- All Implemented Interfaces:
- Serializable, org.apache.spark.api.java.function.Function<org.apache.spark.api.java.JavaPairRDD<K,M>,Void>
public final class SpeedLayerUpdate<K,M,U>
extends Object
implements org.apache.spark.api.java.function.Function<org.apache.spark.api.java.JavaPairRDD<K,M>,Void>
Main Spark Streaming function for the speed layer that collects and publishes update to
a Kafka topic.
- See Also:
- Serialized Form