Class | Description |
---|---|
AbstractSparkLayer<K,M> |
Encapsulates commonality between Spark-based layer processes,
BatchLayer and
SpeedLayer |
AbstractSparkLayer.MMDToTuple2Fn<K,M> |
Translates a
MessageAndMetadata key-message pair to a Tuple2 of the same. |
Functions |
Utility
Function2 implementations. |
TopicProducerImpl<K,M> |
Wraps access to a Kafka message topic
Producer . |
UpdateOffsetsFn<K,M> |
Function that reads offset range from latest RDD in a streaming job, and updates
Zookeeper/Kafka with the latest offset consumed.
|
Copyright © 2014–2015. All rights reserved.