Software Diagram Editor
| Model Diagram | Edit this Diagram
Interface
interface KeyMessage
Simple interface encapsulating a key and message in a topic .
class KeyMessageImpl
Simple value class encapsulati ng a key and message in a top ic.
Interface
interface TopicProducer
Wraps access to a message topi c Producer , including logic to instantiate the object...
Interface
interface BatchLayerUpdate
Implementations of this interf ace define the update process for an instance of the b...
Abstract
abstract class AbstractServingModelManager
Convenience implementation of ServingModelManager that prov ides several default impl...
Interface
interface HasCSV
Implementations of this interf ace can produce a CSV represe ntation. This is useful f...
Abstract
abstract class OryxResource
A utility class that can serve as a superclass of Serving L ayer application endpoint...
class OryxServingException
Thrown by Serving Layer endpoi nts to indicate an error in p rocessing.
Interface
interface ServingModel
Interface that all Serving Lay er in-memory models implement .
Interface
interface ServingModelManager
Implementations of this interf ace maintain, in memory, the current state of a model ...
Abstract
abstract class AbstractSpeedModelManager
Convenience implementation of SpeedModelManager that provid es default implementations.
Interface
interface SpeedModel
Interface that all Speed Layer in-memory models implement.
Interface
interface SpeedModelManager
Implementations of this interf ace maintain, in memory, the current state of a model ...
class ALSUtils
ALS-related utility methods fo r the app tier.
Abstract
abstract class AbstractRescorerProvider
Abstract implementation of Res corerProvider which implement s all methods toreturn nu...
Interface
interface FeatureVectors
Encapsulates a feature vectors , keyed by an ID, and associa ted data structures. This...
class FeatureVectorsPartition
Encapsulates a feature vectors , keyed by an ID, and associa ted data structures. This...
class MultiRescorer
Convenience implementation tha t will aggregate the behavior of multiple Rescorer s. ...
class MultiRescorerProvider
Convenience implementation tha t will aggregate the behavior of RescorerProvider s. I...
class PartitionedFeatureVectors
Encapsulates a feature vectors , keyed by an ID, and associa ted data structures. This...
Interface
interface Rescorer
Implementations of this interf ace can "rescore" the recomme nder's score for a item t...
Interface
interface RescorerProvider
Implementations of this inter face provide, optionally, obj ects that can be used to ...
class SolverCache
A cache around a Solver that m anages computing it when nece ssary from FeatureVectors...
class ALSUpdate
A specialization of MLUpdate that creates a matrix factori zation model of itsinput,...
class EnqueueFeatureVecsAndKnownItemsFn
class EnqueueFeatureVecsFn
class Evaluation
Computes AUC (area under the R OC curve) as a recommender ev aluation metric. Really, ...
Abstract
abstract class AbstractKMeansEvaluation
class ClusterMetric
class DaviesBouldinIndex
class DunnIndex
Enum
enum KMeansEvalStrategy
Evaluation metrics for k-means clustering.
class KMeansUpdate
Update function that builds an d evaluates k-means models in the Batch Layer.
class SilhouetteCoefficient
class SumSquaredError
class Evaluation
class RDFUpdate
Update function that builds an d evaluates random decision f orest models in the Batch...
class CategoricalFeature
Represents a value of a catego rical feature -- one that tak es on discrete, unordered...
class Example
Encapsulates one example, or d ata point: a set of features that predict a target fea...
class ExampleUtils
Utility methods supporting the Example class, like factory methods.
Interface
interface Feature
Implementations represent the value of one feature in an Ex ample .
Enum
enum FeatureType
Represents the type of a Featu re .
class NumericFeature
Represents the value of a nume ric feature -- one that takes on a real value, whether...
class CategoricalPrediction
Represents a prediction of the value of a categorical targe t. The prediction is not ...
class NumericPrediction
Represents a predicted value o f a numeric target. The predi ction is simply a real nu...
Abstract
abstract class Prediction
Subclasses represent the predi cted value of the target.
class WeightedPrediction
A utility class with methods f or combining the results of m any com.cloudera.oryx.app...
class MLFunctions
Contains some reusable functio ns that are useful for ML-rel ated apps from this proje...
class ClusterInfo
Encapsulates a cluster, includ ing its center and number of points assigned to the cl...
Interface
interface DistanceFn
A function that returns a dist ance between things.
class EuclideanDistanceFn
Returns the Euclidean distance between two double[] .
class KMeansPMMLUtils
Utility methods related to PMM L serialization of k-means cl ustering models.
class KMeansUtils
K-means-related utility method s for the app tier.
class AppPMMLUtils
General app tier PMML-related utility methods.
class RDFPMMLUtils
Utility methods related to PMM L serialization of random dec ision forest classificati...
class CategoricalDecision
Represents a decision over a c ategorical feature. If the ca tegorical feature takes o...
Abstract
abstract class Decision
Subclasses represent a binary yes/no positive/negative deci sion based on the value o...
class NumericDecision
Represents a decision over a n umeric feature. Decisions are defined simply by a thre...
class DecisionForest
An ensemble classifier based o n many DecisionTree s.
class DecisionNode
Represents an internal node in a DecisionTree , which encap sulates a binary decision...
class DecisionTree
A decision-tree classifier. Gi ven a set of training Example s, builds a model by ran...
class TerminalNode
Represents a leaf node in a De cisionTree , which contains a Prediction for a targetr...
Interface
interface TreeBasedClassifier
Base interface for decision-tr ee-based classifiers in this package, whether they be ...
Abstract
abstract class TreeNode
Implementations of this interf ace represent nodes in a Deci sionTree , whether leaves...
class TreePath
Encapsulates a path from root to a node in the tree.
class CategoricalValueEncodings
Encapsulates a two-way mapping between the set of values fo r one categorical feature...
class InputSchema
Represents the essential schem a information needed for some learning problems.
Abstract
abstract class AbstractConsoleResource
Superclass of web resources th at contain a small console fo r a Serving Layer applica...
Abstract
abstract class AbstractOryxResource
Superclass of all Serving Laye r application endpoints.
class FileItemPart
Adapter from FileItem to Part , for use in tests while stil l necessary to work aroun...
class IDCount
Encapsulates a String ID and a count.
Abstract
abstract class IDEntity
Superclass of objects that enc apsulate, among other things, a String ID.
class IDValue
Encapsulates a String ID and a floating-point value.
class Ready
Responds to a HEAD or GET req uest to /ready and returns Re sponse.Status#OK or Respo...
Abstract
abstract class AbstractALSResource
Superclass of all Serving Laye r ALS application endpoints.
class AllItemIDs
Responds to a GET request to /item/allIDs . CSV output con sists of one ID per line....
class AllUserIDs
Responds to a GET request to /user/allIDs . CSV output con sists of one ID per line....
class Because
Responds to a GET request to /because/[userID]/[itemID](?h owMany=n)(&offset=o) . Re...
class Console
ALS app Serving Layer console.
class CosineAverageFunction
Computes the cosine of the ang le between a target vector an d other vectors.
Interface
interface CosineDistanceSensitiveFunction
Implementations of this type o f function return a value tha t depends on cosine dista...
class DotsFunction
Computes the dot product of a target vector and other vecto rs.
class Estimate
Responds to a GET request to /estimate/[userID]/[itemID] . The results are opaque v...
class EstimateForAnonymous
Responds to a GET request to /estimateForAnonymous/[toItem ID]/[itemID1(=value1)](/[...
class Ingest
Responds to a POST to /ingest . For each line in the reque st body, a line of CSV te...
class KnownItems
Responds to a GET request to /knownItems/[userID] . CSV ou tput consists of one ID p...
class MostActiveUsers
Responds to a GET request to /mostActiveUsers(?howMany=n)( &offset=o)(&rescorerParam...
class MostPopularItems
Responds to a GET request to /mostPopularItems(?howMany=n) (&offset=o)(&rescorerPara...
class MostSurprising
Responds to a GET request to /mostSurprising/[userID](?how Many=n)(?offset=o) . This...
class PopularRepresentativeItems
Responds to a GET request to /popularRepresentativeItems . The result is a list of ...
class Preference
Responds to a POST request to /pref/[userID]/[itemID] . Th e first line of the reque...
class Recommend
Responds to a GET request to /recommend/[userID](?howMany= n)(&offset=o)(&considerKn...
class RecommendToAnonymous
Responds to a GET request to /recommendToAnonymous/[itemID 1(=value1)](/[itemID2(=va...
class RecommendToMany
Responds to a GET request to /recommendToMany/[userID1](/[ userID2]/...)(?howMany=n)...
class RecommendWithContext
Responds to a GET request to /recommendWithContext/[userID ]/([itemID1(=value1)]/......
class Similarity
Responds to a GET request to /similarity/[itemID1](/[itemI D2]/...)(?howMany=n)(&off...
class SimilarityToItem
Responds to a GET request to /similarityToItem/[toItemID]/ [itemID1](/[itemID2]/...)...
class ALSServingModel
Contains all data structures n eeded to serve real-time requ ests for an ALS-based rec...
class ALSServingModelManager
A com.cloudera.oryx.api.servin g.ServingModelManager that ma nages and provides access...
class LocalitySensitiveHash
class TopNConsumer
class Predict
Responds to a GET request to /predict/[datum] , or a POST to /predict containing se...
class Train
Responds to POST request to / train . The input is one or m ore data points to train,...
Interface
interface ClassificationRegressionServingModel
Implementations are ServingMod el s that specifically suppor t classification or regre...
class Add
Responds to POST request to / add . The input is one or mor e data points to add to t...
class Assign
Responds to a GET request to /assign/[datum] , or a POST t o /assign containing seve...
Interface
interface ClusteringServingModel
Implementations are ServingMod el s that specifically suppor t clustering problems.
class Console
k-means app Serving Layer cons ole.
class DistanceToNearest
Responds to a GET request to /distanceToNearest/[datum] . The inputs is a data poin...
class KMeansServingModel
Contains all data structures n eeded to serve queries for a k-means clustering applic...
class KMeansServingModelManager
A com.cloudera.oryx.api.servin g.ServingModelManager that ma nages and provides access...
class ClassificationDistribution
Responds to a GET request to /classificationDistribution/[ datum] . Like com.clouder...
class Console
Random decision forest app Ser ving Layer console.
class FeatureImportance
Responds to a GET request to /feature/importance or /featu re/importance/[feature nu...
class RDFServingModel
Contains all data structures n eeded to serve queries for a random decision forest-ba...
class RDFServingModelManager
A com.cloudera.oryx.api.servin g.ServingModelManager that ma nages and provides access...
class ALSSpeedModel
Contains all data structures n eeded to create near-real-tim e updates for an ALS-base...
class ALSSpeedModelManager
Implementation of com.cloudera .oryx.api.speed.SpeedModelMan ager that maintains andup...
class UserItemStrength
Represents a user ID, item ID and a strength of interaction between them.
class KMeansSpeedModel
Contains all data structures n eeded to create near-real-tim e updates for a k-means c...
class KMeansSpeedModelManager
Implementation of com.cloudera .oryx.api.speed.SpeedModelMan ager that maintains andup...
class RDFSpeedModel
Contains all data structures n eeded to create near-real-tim e updates for a random de...
class RDFSpeedModelManager
Implementation of com.cloudera .oryx.api.speed.SpeedModelMan ager that maintains andup...
class Main
Runs BatchLayer from the comma nd line. It will use configur ation as loadedby TypeSaf...
Interface
interface CloseableIterator
Implementations are Iterator s that are also Closeable .
class Pair
Encapsulates a pair of objects .
class Pairs
Pair -related utilities.
class IOUtils
I/O-related utility methods.
class AutoLock
Makes a Lock into an AutoClose able for use with try-with-re sources: Lock lock = ...;...
class AutoReadWriteLock
Makes a ReadWriteLock that can return AutoLock s and expose s #autoReadLock() and #au...
class ClassUtils
Class -related utility method s.
class ExecUtils
Utility methods for executing tasks in parallel, possibly r eturning a result and pos...
class JVMUtils
JVM-related utility methods.
class LoggingCallable
A Callable that logs errors th rown from #call() . Useful in cases where it would oth...
class OryxShutdownHook
Intended for use with Runtime# addShutdownHook(Thread) or si milar mechanisms, this is...
class RateLimitCheck
A utility that exposes a #test () method which returns true first, and thenreturn fal...
Interface
interface ToDoubleObjDoubleBiFunction
Analogous to both java.util.fu nction.ToDoubleBiFunction and java.util.function.ObjDo...
class DoubleWeightedMean
A weighted mean implementatio n for floating-point weights, following the Commons Ma...
class LinearSystemSolver
An implementation based on RRQ RDecomposition from Commons M ath.
class SingularMatrixSolverException
Throws when a system can't be solved because the input matr ix is singular or near-si...
class Solver
Encapsulates a DecompositionSo lver from Commons Math.
class VectorMath
Utility class with simple vect or-related operations.
class PMMLUtils
PMML-related utility methods.
class RandomManager
Manages random number generati on. Allows resetting RNGs to a known state for testing.
class ConfigToProperties
Utility that outputs all confi guration as key-value pairs ( as in a .properties file)...
class ConfigUtils
Utilities for retrieving Confi g instances.
class TextUtils
Text and parsing related utili ty methods.
class ExampleBatchLayerUpdate
Input keys are ignored. Values are treated as lines of spac e-separated text. The job...
class Add
Responds to a POST request to /add/[line] . Adds a new line of input for processing....
class Distinct
Responds to a GET request to / distinct . Returns all distin ct words and their count....
class ExampleServingModel
ServingModel produced by Exam pleServingModelManager .
class ExampleServingModelManager
Reads models and updates produ ced by the Batch Layer and Sp eed Layer. Models are map...
class ExampleSpeedModelManager
Also counts and emits counts o f number of distinct words th at occur with words. List...
class ConsumeDataIterator
An iterator over records in a Kafka topic.
class KafkaUtils
Kafka-related utility methods.
Abstract
abstract class AbstractSparkLayer
Encapsulates commonality betwe en Spark-based layer processe s, com.cloudera.oryx.lamb...
class DeleteOldDataFn
Function that deletes old data , if applicable, at each batc h interval.
class HadoopUtils
Hadoop-related utility methods .
class TopicProducerImpl
Wraps access to a Kafka messag e topic Producer .
class UpdateOffsetsFn
Function that reads offset ran ge from latest RDD in a strea ming job, and updates Zoo...
class BatchLayer
Main entry point for Oryx Batc h Layer.
class BatchUpdateFunction
Framework for executing the ba tch layer update, and storing data to persistent stora...
class SaveToHDFSFunction
Function that saves RDDs to HD FS -- only if they're non emp ty, to prevent creation o...
class ScalaBatchLayerUpdateAdapter
Adapts a ScalaBatchLayerUpdate to be a Java BatchLayerUpdat e .
class ValueToWritableFunction
Translates a key and message v alue object into Writable s e ncapsulating the same val...
class ValueWritableConverter
Utility class that automatical ly converts a value object to and from a given, corres...
class WritableToValueFunction
Translates a key and message i n Writable s format to value objects.
class CSVMessageBodyWriter
A MessageBodyWriter that can p roduce CSV ( text/csv ). If g iven an Iterable , produc...
class ErrorResource
Constructs a simple HTML error page from error info in the request. This is intended...
class InMemoryRealm
Adapted from Tomcat's org.apac he.catalina.realm.MemoryRealm . This implementation of...
class ModelManagerListener
ServletContextListener that i nitializes a ServingModelMana ger at webapp startup tim...
class OryxApplication
The single JAX-RS app for the serving-layer.
class OryxExceptionMapper
Maps OryxServingException type s to an HTTP Response .
class ScalaServingModelManagerAdapter
Adapts a ScalaServingModelMana ger to be a Java ServingModel Manager .
class ServingLayer
Top-level implementation of th e Serving Layer process.
class TopicProducerImpl
Wraps access to a Kafka messag e topic Producer .
class ScalaSpeedModelManagerAdapter
Adapts a ScalaSpeedModelManage r to be a Java SpeedModelMana ger .
class SpeedLayer
Main entry point for Oryx Spee d Layer.
class SpeedLayerUpdate
Main Spark Streaming function for the speed layer that coll ects and publishes update...
Abstract
abstract class MLUpdate
A specialization of BatchLayer Update for machine learning-o rientedupdate processes. ...
class ContinuousAround
class ContinuousRange
class DiscreteAround
class DiscreteRange
class GridSearch
Interface
interface HyperParamValues
Encapsulates a range or set of values for a hyperparameter, from which a subset can ...
class HyperParams
Utility methods related to exp ressing and selecting hyperpa rameter values.
class RandomSearch
class Unordered
class Main
Runs ServingLayer from the com mand line. It will use config uration as loadedby TypeS...
class Main
Runs SpeedLayer from the comma nd line. It will use configur ation as loadedby TypeSaf...
Interfaceno source
interface Closeable
Interfaceno source
interface Serializable
no source
class? AutoCloseable
no source
class? Comparable
no source
class? Exception
no source
class? Runnable
no source
class? RuntimeException
Interfaceno source
interface Iterator
no source
class? Callable
inputProducerservingModelManagerlockEMPTY_RESCORER_ARRAY 0..* EMPTY_PROVIDER_ARRAY 0..* partitionMapLockpartitions 0..* vectorPartitionshyperParamValues 0..* clusters 0..* distanceFnevaluationStrategyhyperParamValues 0..* inputSchemahyperParamValues 0..* inputSchemaFEATURE_CACHE 0..* features 0..* ZEROtrees 0..* decisionleftrootpredictionEMPTYXYcachedYTYSolverexpectedItemIDsLocklshrescorerProviderlogRateLimitmodelrescorerProviderNO_RESCOREtopN 0..* clusters 0..* distanceFninputSchemainputSchemamodelencodingsforestinputSchemainputSchemamodelXcachedXTXSolverexpectedItemIDsLocklogRateLimitmodelclusters 0..* distanceFninputSchemamodelencodingsforestinputSchemamodelreadLockSHUTDOWN_HOOKSHUTDOWN_HOOKupdateInstancekeyConverterkeyConverterconsumerIteratorinputProducermodelManagerconsumerIteratormodelManagermodelManager