- Type Parameters:
K
- RDD element's key type (not used)
M
- RDD element's value type (not used)
- All Implemented Interfaces:
- Serializable, org.apache.spark.api.java.function.VoidFunction<org.apache.spark.api.java.JavaRDD<kafka.message.MessageAndMetadata<K,M>>>
public final class UpdateOffsetsFn<K,M>
extends Object
implements org.apache.spark.api.java.function.VoidFunction<org.apache.spark.api.java.JavaRDD<kafka.message.MessageAndMetadata<K,M>>>
Function that reads offset range from latest RDD in a streaming job, and updates
Zookeeper/Kafka with the latest offset consumed.
- See Also:
- Serialized Form