Oryx Architecture Diagrams | documentation produced by SourceSpy

Package com.cloudera.oryx.lambda.speed

https://github.com/OryxProject/oryx/tree/master/framework/oryx-lambda/src/test/java/com/cloudera/oryx/lambda/speed
Contains the core support for the Lambda tier of the Speed Layers.
Classes
com.cloudera.oryx.kafka.util
org.slf4j
com.cloudera.oryx.common.settings
com.typesafe.config
com.cloudera.oryx.common.lang
Package Dependencies
AbstractLambdaIT (abstr)
Superclass of test cases for this module. Takes care of setting up services like Kafka and Zookee...
com.cloudera.oryx.common.collection
com.cloudera.oryx.api
AbstractSpeedIT (abstr)
MockModelGenerator
DatumGenerator
MockSpeedModelManager
SpeedModelManager
ScalaSpeedModelManagerAdapter
SpeedLayer
AbstractSparkLayer (abstr)
SpeedLayerIT
SpeedLayerUpdate
VoidFunction
Interface which generates one datum. @param < K > key type @param < M > message type
Implementations of this interface maintain, in memory, the current state of a model in the speed ...
Adapts a ScalaSpeedModelManager to be a Java SpeedModelManager . @param < K > type of key read fr...
Main entry point for Oryx Speed Layer. @param < K > type of key read from input topic @param < M ...
Encapsulates commonality between Spark-based layer processes, com.cloudera.oryx.lambda.batch.Batc...
Tests SpeedLayer .
Main Spark Streaming function for the speed layer that collects and publishes update to a Kafka t...
com.cloudera.oryx.lambda.speed
com.cloudera.oryx.api.speed
org.apache.spark.streaming.api.java