Software Diagram Editor
| com.cloudera.oryx.lambda | Edit this Diagram
Interface
interface TopicProducer
Wraps access to a message topi c Producer , including logic to instantiate the object...
class OryxShutdownHook
Intended for use with Runtime# addShutdownHook(Thread) or si milar mechanisms, this is...
Abstract
abstract class AbstractSparkLayer
Encapsulates commonality betwe en Spark-based layer processe s, com.cloudera.oryx.lamb...
class DeleteOldDataFn
Function that deletes old data , if applicable, at each batc h interval.
class HadoopUtils
Hadoop-related utility methods .
class TopicProducerImpl
Wraps access to a Kafka messag e topic Producer .
class UpdateOffsetsFn
Function that reads offset ran ge from latest RDD in a strea ming job, and updates Zoo...
Interfaceno source
interface Closeable
SHUTDOWN_HOOK