abstract class AbstractSparkLayer
Encapsulates commonality between Spark-based layer processes, com.cloud...
Function that deletes old data, if applicable, at each batch interval.
Hadoop-related utility methods.
Wraps access to a Kafka message topic Producer .
Function that reads offset range from latest RDD in a streaming job, an...
Wraps access to a message topic Producer , including logic to instantia...