Uses of Interface
com.cloudera.oryx.api.KeyMessage

Packages that use KeyMessage

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.kafka.util	Kafka-related utility code and command-line applications.
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.

Uses of KeyMessage in com.cloudera.oryx.api

Classes in com.cloudera.oryx.api that implement KeyMessage

Modifier and Type	Class and Description
class	KeyMessageImpl<K,M> Simple value class encapsulating a key and message in a topic.

Uses of KeyMessage in com.cloudera.oryx.api.serving

Method parameters in com.cloudera.oryx.api.serving with type arguments of type KeyMessage

Modifier and Type	Method and Description
void	AbstractServingModelManager.consume(Iterator<KeyMessage<String,U>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf)
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.

Uses of KeyMessage in com.cloudera.oryx.api.speed

Method parameters in com.cloudera.oryx.api.speed with type arguments of type KeyMessage

Modifier and Type	Method and Description
void	AbstractSpeedModelManager.consume(Iterator<KeyMessage<String,U>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf)
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.

Uses of KeyMessage in com.cloudera.oryx.kafka.util

Methods in com.cloudera.oryx.kafka.util that return KeyMessage

Modifier and Type	Method and Description
protected KeyMessage<K,V>	ConsumeDataIterator.computeNext()

Uses of KeyMessage in com.cloudera.oryx.lambda.serving

Method parameters in com.cloudera.oryx.lambda.serving with type arguments of type KeyMessage

Modifier and Type	Method and Description
void	ScalaServingModelManagerAdapter.consume(Iterator<KeyMessage<String,U>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf)

Uses of KeyMessage in com.cloudera.oryx.lambda.speed

Method parameters in com.cloudera.oryx.lambda.speed with type arguments of type KeyMessage

Modifier and Type	Method and Description
void	ScalaSpeedModelManagerAdapter.consume(Iterator<KeyMessage<String,U>> updateIterator, org.apache.hadoop.conf.Configuration hadoopConf)