| Generated and automatically maintained for github.com/OryxProject/oryx by SourceSpy
GitHub Project BadgeCopy: HTML Markdown

Package com.cloudera.oryx

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