Package com.cloudera.oryx.lambda

Code used across the Lambda tier.

See: Description

Class Summary

Class	Description
AbstractSparkLayer<K,M>	Encapsulates commonality between Spark-based layer processes, BatchLayer and SpeedLayer
DeleteOldDataFn<T>	Function that deletes old data, if applicable, at each batch interval.
HadoopUtils	Hadoop-related utility methods.
TopicProducerImpl<K,M>	Wraps access to a Kafka message topic Producer.
UpdateOffsetsFn<T>	Function that reads offset range from latest RDD in a streaming job, and updates Zookeeper/Kafka with the latest offset consumed.

Package com.cloudera.oryx.lambda Description

Code used across the Lambda tier.