- 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.Function<org.apache.spark.api.java.JavaRDD<kafka.message.MessageAndMetadata<K,M>>,Void>
public final class UpdateOffsetsFn<K,M>
extends Object
implements org.apache.spark.api.java.function.Function<org.apache.spark.api.java.JavaRDD<kafka.message.MessageAndMetadata<K,M>>,Void>
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