| Generated and automatically maintained for github.com/OryxProject/oryx by SourceSpy
GitHub Project BadgeCopy: HTML Markdown

Package com.cloudera.oryx.lambda

com.cloudera.oryx.lambda
Abstract
AbstractSparkLayer
Encapsulates commonality betwe en Spark-based layer processe s, com.cloudera.oryx.lamb...
DeleteOldDataFn
Function that deletes old data , if applicable, at each batc h interval.
HadoopUtils
Hadoop-related utility methods .
TopicProducerImpl
Wraps access to a Kafka messag e topic Producer .
UpdateOffsetsFn
Function that reads offset ran ge from latest RDD in a strea ming job, and updates Zoo...
com.cloudera.oryx.lambda.batch
BatchLayer
Main entry point for Oryx Batc h Layer.
BatchUpdateFunction
Framework for executing the ba tch layer update, and storing data to persistent stora...
SaveToHDFSFunction
Function that saves RDDs to HD FS -- only if they're non emp ty, to prevent creation o...
ScalaBatchLayerUpdateAdapter
Adapts a ScalaBatchLayerUpdate to be a Java BatchLayerUpdat e .
ValueToWritableFunction
Translates a key and message v alue object into Writable s e ncapsulating the same val...
ValueWritableConverter
Utility class that automatical ly converts a value object to and from a given, corres...
WritableToValueFunction
Translates a key and message i n Writable s format to value objects.
com.cloudera.oryx.lambda.serving
CSVMessageBodyWriter
A MessageBodyWriter that can p roduce CSV ( text/csv ). If g iven an Iterable , produc...
ErrorResource
Constructs a simple HTML error page from error info in the request. This is intended...
InMemoryRealm
Adapted from Tomcat's org.apac he.catalina.realm.MemoryRealm . This implementation of...
ModelManagerListener
ServletContextListener that i nitializes a ServingModelMana ger at webapp startup tim...
OryxApplication
The single JAX-RS app for the serving-layer.
OryxExceptionMapper
Maps OryxServingException type s to an HTTP Response .
ScalaServingModelManagerAdapter
Adapts a ScalaServingModelMana ger to be a Java ServingModel Manager .
ServingLayer
Top-level implementation of th e Serving Layer process.
TopicProducerImpl
Wraps access to a Kafka messag e topic Producer .
com.cloudera.oryx.lambda.speed
ScalaSpeedModelManagerAdapter
Adapts a ScalaSpeedModelManage r to be a Java SpeedModelMana ger .
SpeedLayer
Main entry point for Oryx Spee d Layer.
SpeedLayerUpdate
Main Spark Streaming function for the speed layer that coll ects and publishes update...