Package | Description |
---|---|
com.cloudera.oryx.api |
Application API interface classes common to all Layers.
|
com.cloudera.oryx.api.serving |
Application API interface classes for the Serving Layer.
|
com.cloudera.oryx.api.speed |
Application API interface classes for the Speed Layer.
|
com.cloudera.oryx.app.serving.als.model |
Data model support for the ALS recommender Serving Layer app.
|
com.cloudera.oryx.app.serving.kmeans.model |
Data model support for the k-means clustering Serving Layer app.
|
com.cloudera.oryx.app.serving.rdf.model |
Data model support for the random decision forest Serving Layer app.
|
com.cloudera.oryx.app.speed.als |
Contains an app tier implementation of a Speed Layer, for ALS recommendation.
|
com.cloudera.oryx.app.speed.kmeans |
Contains an app tier implementation of a Speed Layer, for ALS recommendation.
|
com.cloudera.oryx.app.speed.rdf |
Contains an app tier implementation of a Speed Layer, for random decision forest
classification and regression.
|
com.cloudera.oryx.example.serving |
Contains a minimal example of what a user application would create to implement a
Serving Layer.
|
com.cloudera.oryx.example.speed |
Contains a minimal example of what a user application would create to implement a
Speed Layer.
|
com.cloudera.oryx.lambda.serving |
Contains the core support for the Lambda tier of the Serving Layers.
|
com.cloudera.oryx.lambda.speed |
Contains the core support for the Lambda tier of the Speed Layers.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyMessageImpl<K,M>
Simple value class encapsulating a key and message in a topic.
|
Modifier and Type | Method and Description |
---|---|
void |
ServingModelManager.consume(Iterator<KeyMessage<String,U>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf)
Called by the framework to initiate a continuous process of reading models, and reading
from the input topic and updating model state in memory, and issuing updates to the
update topic.
|
Modifier and Type | Method and Description |
---|---|
void |
SpeedModelManager.consume(Iterator<KeyMessage<String,U>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf)
Called by the framework to initiate a continuous process of reading models, and reading
from the input topic and updating model state in memory, and issuing updates to the
update topic.
|
Modifier and Type | Method and Description |
---|---|
void |
ALSServingModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
KMeansServingModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf)
Called by the framework to initiate a continuous process of reading models, and reading
from the input topic and updating model state in memory, and issuing updates to the
update topic.
|
Modifier and Type | Method and Description |
---|---|
void |
RDFServingModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf)
Called by the framework to initiate a continuous process of reading models, and reading
from the input topic and updating model state in memory, and issuing updates to the
update topic.
|
Modifier and Type | Method and Description |
---|---|
void |
ALSSpeedModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
KMeansSpeedModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
RDFSpeedModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
ExampleServingModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
ExampleSpeedModelManager.consume(Iterator<KeyMessage<String,String>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
ScalaServingModelManagerAdapter.consume(Iterator<KeyMessage<String,U>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Modifier and Type | Method and Description |
---|---|
void |
ScalaSpeedModelManagerAdapter.consume(Iterator<KeyMessage<String,U>> updateIterator,
org.apache.hadoop.conf.Configuration hadoopConf) |
Copyright © 2014–2016. All rights reserved.