Function that deletes old data, if applicable, at each batch interval.
Hadoop-related utility methods.
Wraps access to a Kafka message topic
Function that reads offset range from latest RDD in a streaming job, and updates Zookeeper/Kafka with the latest offset consumed.
Copyright © 2014–2018. All rights reserved.