/OryxProject/oryx[edit]
Copy Badge: HTML Markdown

Package com.cloudera.oryx.lambda

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