Architecture Diagrams for /oryxproject/oryx[edit]
Packages / Module oryx-lambda / com.cloudera.oryx.lambda

Package com.cloudera.oryx.lambda

Code used across the Lambda tier.
com.cloudera.oryx.lambda
A
AbstractSparkLayer
Encapsulates commonality between Spark-based layer processes, com.cloud...
DeleteOldDataFn
Function that deletes old data, if applicable, at each batch interval.
HadoopUtils
Hadoop-related utility methods.
TopicProducerImpl
Wraps access to a Kafka message topic Producer .
UpdateOffsetsFn
Function that reads offset range from latest RDD in a streaming job, an...
com.cloudera.oryx.lambda.batch
BatchLayer
Main entry point for Oryx Batch Layer.
BatchUpdateFunction
Framework for executing the batch layer update, and storing data to per...
SaveToHDFSFunction
Function that saves RDDs to HDFS -- only if they're non empty, to preve...
ScalaBatchLayerUpdateAdapter
Adapts a ScalaBatchLayerUpdate to be a Java BatchLayerUpdate .
ValueToWritableFunction
Translates a key and message value object into Writable s encapsulating...
ValueWritableConverter
Utility class that automatically converts a value object to and from a ...
WritableToValueFunction
Translates a key and message in Writable s format to value objects.
com.cloudera.oryx.lambda.serving
CSVMessageBodyWriter
A MessageBodyWriter that can produce CSV ( text/csv ). If given an Iter...
ErrorResource
Constructs a simple HTML error page from error info in the request. Thi...
InMemoryRealm
Adapted from Tomcat's org.apache.catalina.realm.MemoryRealm . This impl...
ModelManagerListener
ServletContextListener that initializes a ServingModelManager at webap...
OryxApplication
The single JAX-RS app for the serving-layer.
OryxExceptionMapper
Maps OryxServingException types to an HTTP Response .
ScalaServingModelManagerAdapter
Adapts a ScalaServingModelManager to be a Java ServingModelManager .
ServingLayer
Top-level implementation of the Serving Layer process.
TopicProducerImpl
Wraps access to a Kafka message topic Producer .
com.cloudera.oryx.lambda.speed
ScalaSpeedModelManagerAdapter
Adapts a ScalaSpeedModelManager to be a Java SpeedModelManager .
SpeedLayer
Main entry point for Oryx Speed Layer.
SpeedLayerUpdate
Main Spark Streaming function for the speed layer that collects and pub...