Skip navigation links
A B C F G I L M N R S T U 

A

AbstractSparkLayer<K,M> - Class in com.cloudera.oryx.lambda
Encapsulates commonality between Spark-based layer processes, BatchLayer and SpeedLayer
AbstractSparkLayer(Config) - Constructor for class com.cloudera.oryx.lambda.AbstractSparkLayer
 
AbstractSparkLayer.MMDToTuple2Fn<K,M> - Class in com.cloudera.oryx.lambda
Translates a MessageAndMetadata key-message pair to a Tuple2 of the same.
await() - Method in class com.cloudera.oryx.lambda.batch.BatchLayer
 
await() - Method in class com.cloudera.oryx.lambda.speed.SpeedLayer
 

B

BatchLayer<K,M,U> - Class in com.cloudera.oryx.lambda.batch
Main entry point for Oryx Batch Layer.
BatchLayer(Config) - Constructor for class com.cloudera.oryx.lambda.batch.BatchLayer
 
buildInputDStream(JavaStreamingContext) - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
buildStreamingContext() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
buildUpdates(JavaPairRDD<K, M>) - Method in class com.cloudera.oryx.lambda.speed.ScalaSpeedModelManagerAdapter
 

C

call(MessageAndMetadata<K, M>) - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer.MMDToTuple2Fn
 
call(JavaPairRDD<K, M>) - Method in class com.cloudera.oryx.lambda.speed.SpeedLayerUpdate
 
call(JavaRDD<MessageAndMetadata<K, M>>) - Method in class com.cloudera.oryx.lambda.UpdateOffsetsFn
 
close() - Method in class com.cloudera.oryx.lambda.batch.BatchLayer
 
close() - Method in class com.cloudera.oryx.lambda.speed.ScalaSpeedModelManagerAdapter
 
close() - Method in class com.cloudera.oryx.lambda.speed.SpeedLayer
 
close() - Method in class com.cloudera.oryx.lambda.TopicProducerImpl
 
com.cloudera.oryx.lambda - package com.cloudera.oryx.lambda
Code used across the Lambda tier.
com.cloudera.oryx.lambda.batch - package com.cloudera.oryx.lambda.batch
Contains the core support for the Lambda tier of the Batch Layers.
com.cloudera.oryx.lambda.speed - package com.cloudera.oryx.lambda.speed
Contains the core support for the Lambda tier of the Speed Layers.
consume(Iterator<KeyMessage<String, U>>, Configuration) - Method in class com.cloudera.oryx.lambda.speed.ScalaSpeedModelManagerAdapter
 

F

Functions - Class in com.cloudera.oryx.lambda
Utility Function2 implementations.

G

getConfig() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getConfigGroup() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getConfigGroup() - Method in class com.cloudera.oryx.lambda.batch.BatchLayer
 
getConfigGroup() - Method in class com.cloudera.oryx.lambda.speed.SpeedLayer
 
getGroupID() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getID() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getInputTopicLockMaster() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getKeyClass() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getLayerName() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getLayerName() - Method in class com.cloudera.oryx.lambda.batch.BatchLayer
 
getLayerName() - Method in class com.cloudera.oryx.lambda.speed.SpeedLayer
 
getMessageClass() - Method in class com.cloudera.oryx.lambda.AbstractSparkLayer
 
getTopic() - Method in class com.cloudera.oryx.lambda.TopicProducerImpl
 
getUpdateBroker() - Method in class com.cloudera.oryx.lambda.TopicProducerImpl
 

I

identity() - Static method in class com.cloudera.oryx.lambda.Functions
 

L

last() - Static method in class com.cloudera.oryx.lambda.Functions
 

M

MMDToTuple2Fn() - Constructor for class com.cloudera.oryx.lambda.AbstractSparkLayer.MMDToTuple2Fn
 

N

noOp() - Static method in class com.cloudera.oryx.lambda.Functions
 

R

runUpdate(JavaSparkContext, long, JavaPairRDD<K, M>, JavaPairRDD<K, M>, String, TopicProducer<String, U>) - Method in class com.cloudera.oryx.lambda.batch.ScalaBatchLayerUpdateAdapter
 

S

ScalaBatchLayerUpdateAdapter<K,M,U> - Class in com.cloudera.oryx.lambda.batch
ScalaBatchLayerUpdateAdapter(ScalaBatchLayerUpdate<K, M, U>) - Constructor for class com.cloudera.oryx.lambda.batch.ScalaBatchLayerUpdateAdapter
 
ScalaSpeedModelManagerAdapter<K,M,U> - Class in com.cloudera.oryx.lambda.speed
ScalaSpeedModelManagerAdapter(ScalaSpeedModelManager<K, M, U>) - Constructor for class com.cloudera.oryx.lambda.speed.ScalaSpeedModelManagerAdapter
 
send(K, M) - Method in class com.cloudera.oryx.lambda.TopicProducerImpl
 
SpeedLayer<K,M,U> - Class in com.cloudera.oryx.lambda.speed
Main entry point for Oryx Speed Layer.
SpeedLayer(Config) - Constructor for class com.cloudera.oryx.lambda.speed.SpeedLayer
 
SpeedLayerUpdate<K,M,U> - Class in com.cloudera.oryx.lambda.speed
Main Spark Streaming function for the speed layer that collects and publishes update to a Kafka topic.
SpeedLayerUpdate(SpeedModelManager<K, M, U>, String, String) - Constructor for class com.cloudera.oryx.lambda.speed.SpeedLayerUpdate
 
start() - Method in class com.cloudera.oryx.lambda.batch.BatchLayer
 
start() - Method in class com.cloudera.oryx.lambda.speed.SpeedLayer
 

T

TopicProducerImpl<K,M> - Class in com.cloudera.oryx.lambda
Wraps access to a Kafka message topic Producer.
TopicProducerImpl(String, String, boolean) - Constructor for class com.cloudera.oryx.lambda.TopicProducerImpl
 

U

UpdateOffsetsFn<K,M> - Class in com.cloudera.oryx.lambda
Function that reads offset range from latest RDD in a streaming job, and updates Zookeeper/Kafka with the latest offset consumed.
UpdateOffsetsFn(String, String) - Constructor for class com.cloudera.oryx.lambda.UpdateOffsetsFn
 
A B C F G I L M N R S T U 
Skip navigation links

Copyright © 2014–2015. All rights reserved.