Architecture Diagrams for /oryxproject/oryx[edit]
Packages

Overview

Packages, Classes, Methods, Fields
Generated on 16 Jan 2020 04:02:04 GMT
 
 
Module example gh
 
Package com.cloudera.oryx.example.batch // Contains a minimal example of what a user application would create to i...
 
class ExampleBatchLayerUpdate overview flow hierarchy // Input keys are ignored. Values are treated as lines of space-separated ...
 
Package com.cloudera.oryx.example.serving // Contains a minimal example of what a user application would create to i...
 
class Add overview flow hierarchy // Responds to a POST request to /add/[line] . Adds a new line of input fo...
method add() logic callers
method getProducer() logic callers
method post() logic callers
 
class Distinct overview flow hierarchy // Responds to a GET request to /distinct . Returns all distinct words and...
method get() logic callers
method get() logic callers
method getModel() logic callers
 
class ExampleServingModel overview flow hierarchy // ServingModel produced by ExampleServingModelManager .
constructor ExampleServingModel() logic callers
method getFractionLoaded() logic callers
method getWords() logic callers
 
class ExampleServingModelManager overview flow hierarchy // Reads models and updates produced by the Batch Layer and Speed Layer. M...
method getModel() logic callers
 
Package com.cloudera.oryx.example.speed // Contains a minimal example of what a user application would create to i...
 
class ExampleSpeedModelManager overview flow hierarchy // Also counts and emits counts of number of distinct words that occur wit...
 
Module kafka-util gh
 
Package com.cloudera.oryx.kafka.util // Kafka-related utility code and command-line applications.
 
class ConsumeDataIterator overview flow hierarchy // An iterator over records in a Kafka topic.
method close() logic callers
method computeNext() logic callers
 
class KafkaUtils overview flow hierarchy // Kafka-related utility methods.
constructor KafkaUtils() logic callers
method deleteTopic() logic callers
method maybeCreateTopic() logic callers
method maybeCreateTopic() logic callers
method setOffsets() logic callers
method topicExists() logic callers
 
Module oryx gh
 
Module oryx-api gh
 
Package com.cloudera.oryx.api // Application API interface classes common to all Layers.
 
interface KeyMessage overview flow hierarchy // Simple interface encapsulating a key and message in a topic.
method getKey() logic callers
method getMessage() logic callers
 
class KeyMessageImpl overview flow hierarchy // Simple value class encapsulating a key and message in a topic.
constructor KeyMessageImpl() logic callers
method equals() logic callers
method getKey() logic callers
method getMessage() logic callers
method hashCode() logic callers
method toString() logic callers
 
interface TopicProducer overview flow hierarchy // Wraps access to a message topic Producer , including logic to instantia...
method close() logic callers
method getTopic() logic callers
method getUpdateBroker() logic callers
method send() logic callers
method send() logic callers
 
Package com.cloudera.oryx.api.batch // Application API interface classes for the Batch Layer.
 
interface BatchLayerUpdate overview flow hierarchy // Implementations of this interface define the update process for an inst...
 
Package com.cloudera.oryx.api.serving // Application API interface classes for the Serving Layer.
 
class AbstractServingModelManager overview flow hierarchy // Convenience implementation of ServingModelManager that provides several...
method isReadOnly() logic callers
 
interface HasCSV overview flow hierarchy // Implementations of this interface can produce a CSV representation. Thi...
method toCSV() logic callers
 
class OryxResource overview flow hierarchy // A utility class that can serve as a superclass of Serving Layer applica...
method getInputProducer() logic callers
method getServingModelManager() logic callers
method init() logic callers
 
class OryxServingException overview flow hierarchy // Thrown by Serving Layer endpoints to indicate an error in processing.
 
interface ServingModel overview flow hierarchy // Interface that all Serving Layer in-memory models implement.
method getFractionLoaded() logic callers
 
interface ServingModelManager overview flow hierarchy // Implementations of this interface maintain, in memory, the current stat...
method close() logic callers
method getConfig() logic callers
method getModel() logic callers
method isReadOnly() logic callers
 
Package com.cloudera.oryx.api.speed // Application API interface classes for the Speed Layer.
 
class AbstractSpeedModelManager overview flow hierarchy // Convenience implementation of SpeedModelManager that provides default i...
 
interface SpeedModel overview flow hierarchy // Interface that all Speed Layer in-memory models implement.
method getFractionLoaded() logic callers
 
interface SpeedModelManager overview flow hierarchy // Implementations of this interface maintain, in memory, the current stat...
method close() logic callers
method consume() logic callers
 
Module oryx-app gh
 
Package com.cloudera.oryx.app.speed.als // Contains an app tier implementation of a Speed Layer, for ALS recommend...
 
class ALSSpeedModel overview flow hierarchy // Contains all data structures needed to create near-real-time updates fo...
constructor ALSSpeedModel() logic callers // Creates an empty model.
method getEpsilon() logic callers
method getFeatures() logic callers
method getFractionLoaded() logic callers
method getItemVector() logic callers
method getUserVector() logic callers
method getXTXSolver() logic callers
method getYTYSolver() logic callers
method isImplicit() logic callers
method isLogStrength() logic callers
method precomputeSolvers() logic callers
method retainRecentAndItemIDs() logic callers
method retainRecentAndUserIDs() logic callers
method setItemVector() logic callers
method setUserVector() logic callers
method toString() logic callers
 
class ALSSpeedModelManager overview flow hierarchy // Implementation of com.cloudera.oryx.api.speed.SpeedModelManager that ma...
method toUpdateJSON() logic callers
 
class UserItemStrength overview flow hierarchy // Represents a user ID, item ID and a strength of interaction between them.
constructor UserItemStrength() logic callers
method getItem() logic callers
method getStrength() logic callers
method getUser() logic callers
method toString() logic callers
 
Package com.cloudera.oryx.app.speed.kmeans // Contains an app tier implementation of a Speed Layer, for ALS recommend...
 
class KMeansSpeedModel overview flow hierarchy // Contains all data structures needed to create near-real-time updates fo...
constructor KMeansSpeedModel() logic callers
method closestCluster() logic callers
method getCluster() logic callers
method getFractionLoaded() logic callers
method setCluster() logic callers
method toString() logic callers
 
class KMeansSpeedModelManager overview flow hierarchy // Implementation of com.cloudera.oryx.api.speed.SpeedModelManager that ma...
 
Package com.cloudera.oryx.app.speed.rdf // Contains an app tier implementation of a Speed Layer, for random decisi...
 
class RDFSpeedModel overview flow hierarchy // Contains all data structures needed to create near-real-time updates fo...
constructor RDFSpeedModel() logic callers
method getEncodings() logic callers
method getForest() logic callers
method getFractionLoaded() logic callers
method toString() logic callers
 
class RDFSpeedModelManager overview flow hierarchy // Implementation of com.cloudera.oryx.api.speed.SpeedModelManager that ma...
 
Module oryx-app-api gh
 
Package com.cloudera.oryx.app.als // Support code for rALS recommender application functionality common to s...
 
class AbstractRescorerProvider overview flow hierarchy // Abstract implementation of RescorerProvider which implements all method...
method getMostActiveUsersRescorer() logic callers
method getMostPopularItemsRescorer() logic callers
method getMostSimilarItemsRescorer() logic callers
method getRecommendRescorer() logic callers
method getRecommendToAnonymousRescorer() logic callers
 
class MultiRescorer overview flow hierarchy // Convenience implementation that will aggregate the behavior of multiple...
constructor MultiRescorer() logic callers
method getRescorers() logic callers
method isFiltered() logic callers
method of() logic callers
method of() logic callers
method rescore() logic callers
 
class MultiRescorerProvider overview flow hierarchy // Convenience implementation that will aggregate the behavior of Rescorer...
constructor MultiRescorerProvider() logic callers
method buildRescorer() logic callers
method getMostActiveUsersRescorer() logic callers
method getMostPopularItemsRescorer() logic callers
method getMostSimilarItemsRescorer() logic callers
method getProviders() logic callers
method getRecommendRescorer() logic callers
method getRecommendToAnonymousRescorer() logic callers
method of() logic callers
 
interface Rescorer overview flow hierarchy // Implementations of this interface can "rescore" the recommender's score...
method isFiltered() logic callers
method rescore() logic callers
 
interface RescorerProvider overview flow hierarchy // Implementations of this interface provide, optionally, objects that ca...
method getMostActiveUsersRescorer() logic callers
method getMostPopularItemsRescorer() logic callers
method getMostSimilarItemsRescorer() logic callers
method getRecommendRescorer() logic callers
method getRecommendToAnonymousRescorer() logic callers
 
Module oryx-app-common gh
 
Package com.cloudera.oryx.app.als // Support code for rALS recommender application functionality common to s...
 
class ALSUtils overview flow hierarchy // ALS-related utility methods for the app tier.
constructor ALSUtils() logic callers
method computeTargetQui() logic callers // Computes how the estimated strength of interaction in the model should ...
method computeUpdatedXu() logic callers // Computes how a user vector Xu changes in response to interaction with a...
 
interface FeatureVectors overview flow hierarchy // Encapsulates a feature vectors, keyed by an ID, and associated data str...
method addAllIDsTo() logic callers // Adds all IDs that are mapped to a feature vector to a given collection
method addAllRecentTo() logic callers // Add all recently set IDs to the given collection
method getVTV() logic callers
method getVector() logic callers
method removeAllIDsFrom() logic callers // Removes all IDs that are mapped to a feature vector from a given collec...
method retainRecentAndIDs() logic callers // Given IDs that are part of a new model, and whose values are going to b...
method setVector() logic callers // Sets the value of a feature vector for an ID. If no feature vector prev...
method size() logic callers
 
class FeatureVectorsPartition overview flow hierarchy // Encapsulates a feature vectors, keyed by an ID, and associated data str...
constructor FeatureVectorsPartition() logic callers
method addAllIDsTo() logic callers
method addAllRecentTo() logic callers
method forEach() logic callers
method getVTV() logic callers
method getVector() logic callers
method removeAllIDsFrom() logic callers
method removeVector() logic callers
method retainRecentAndIDs() logic callers
method setVector() logic callers
method size() logic callers
method toString() logic callers
 
class PartitionedFeatureVectors overview flow hierarchy // Encapsulates a feature vectors, keyed by an ID, and associated data str...
constructor PartitionedFeatureVectors() logic callers
constructor PartitionedFeatureVectors() logic callers
method addAllIDsTo() logic callers
method addAllRecentTo() logic callers
method getVTV() logic callers
method getVector() logic callers
method mapPartitionsParallel() logic callers
method mapPartitionsParallel() logic callers
method removeAllIDsFrom() logic callers
method retainRecentAndIDs() logic callers
method setVector() logic callers
method size() logic callers
method toString() logic callers
 
class SolverCache overview flow hierarchy // A cache around a Solver that manages computing it when necessary from F...
constructor SolverCache() logic callers
method compute() logic callers // Proactively try to compute the solver asynchronously, if not already co...
method get() logic callers
method setDirty() logic callers // Indicates that the underlying {@link FeatureVectors} have changed and s...
 
Package com.cloudera.oryx.app.classreg.example // Representations of features and training / test examples that are used ...
 
class CategoricalFeature overview flow hierarchy // Represents a value of a categorical feature -- one that takes on discre...
constructor CategoricalFeature() logic callers
method equals() logic callers
method forEncoding() logic callers
method getEncoding() logic callers
method getFeatureType() logic callers
method hashCode() logic callers
method toString() logic callers
 
class Example overview flow hierarchy // Encapsulates one example, or data point: a set of features that predict...
constructor Example() logic callers
method equals() logic callers
method getFeature() logic callers
method getTarget() logic callers
method hashCode() logic callers
method toString() logic callers
 
class ExampleUtils overview flow hierarchy // Utility methods supporting the Example class, like factory methods.
constructor ExampleUtils() logic callers
method dataToExample() logic callers
 
interface Feature overview flow hierarchy // Implementations represent the value of one feature in an Example .
method getFeatureType() logic callers
 
enum FeatureType overview flow hierarchy // Represents the type of a Feature .
 
class NumericFeature overview flow hierarchy // Represents the value of a numeric feature -- one that takes on a real v...
constructor NumericFeature() logic callers
method equals() logic callers
method forValue() logic callers
method getFeatureType() logic callers
method getValue() logic callers
method hashCode() logic callers
method toString() logic callers
 
Package com.cloudera.oryx.app.classreg.predict // Representations of the output of a classification or regression process.
 
class CategoricalPrediction overview flow hierarchy // Represents a prediction of the value of a categorical target. The predi...
constructor CategoricalPrediction() logic callers
constructor CategoricalPrediction() logic callers
method equals() logic callers
method getCategoryCounts() logic callers
method getCategoryProbabilities() logic callers
method getFeatureType() logic callers
method getMostProbableCategoryEncoding() logic callers
method hashCode() logic callers
method recompute() logic callers
method sum() logic callers
method toDoubles() logic callers
method toString() logic callers
method update() logic callers
method update() logic callers
 
class NumericPrediction overview flow hierarchy // Represents a predicted value of a numeric target. The prediction is sim...
constructor NumericPrediction() logic callers
method equals() logic callers
method getFeatureType() logic callers
method getPrediction() logic callers
method hashCode() logic callers
method toString() logic callers
method update() logic callers
method update() logic callers
 
class Prediction overview flow hierarchy // Subclasses represent the predicted value of the target.
constructor Prediction() logic callers
method getCount() logic callers
method getFeatureType() logic callers
method setCount() logic callers
method toString() logic callers
method update() logic callers
 
class WeightedPrediction overview flow hierarchy // A utility class with methods for combining the results of many com.clou...
constructor WeightedPrediction() logic callers
method voteOnCategoricalFeature() logic callers
method voteOnFeature() logic callers
method voteOnNumericFeature() logic callers
 
Package com.cloudera.oryx.app.common.fn // Contains Java Functions useful across ML tier implementations.
 
class MLFunctions overview flow hierarchy // Contains some reusable functions that are useful for ML-related apps fr...
constructor MLFunctions() logic callers
 
Package com.cloudera.oryx.app.kmeans // Support code for the k-means application functionality common to severa...
 
class ClusterInfo overview flow hierarchy // Encapsulates a cluster, including its center and number of points assig...
constructor ClusterInfo() logic callers
method getCenter() logic callers
method getCount() logic callers
method getID() logic callers
method toString() logic callers
method update() logic callers
 
interface DistanceFn overview flow hierarchy // A function that returns a distance between things.
 
class EuclideanDistanceFn overview flow hierarchy // Returns the Euclidean distance between two double[] .
constructor EuclideanDistanceFn() logic callers
method applyAsDouble() logic callers
 
class KMeansPMMLUtils overview flow hierarchy // Utility methods related to PMML serialization of k-means clustering mod...
constructor KMeansPMMLUtils() logic callers
 
class KMeansUtils overview flow hierarchy // K-means-related utility methods for the app tier.
constructor KMeansUtils() logic callers
method checkUniqueIDs() logic callers
method closestCluster() logic callers
method featuresFromTokens() logic callers
 
Package com.cloudera.oryx.app.pmml // Utility code related to parsing, writing and manipulating PMML represen...
 
class AppPMMLUtils overview flow hierarchy // General app tier PMML-related utility methods.
constructor AppPMMLUtils() logic callers
 
Package com.cloudera.oryx.app.rdf // Support code for random decision forest application functionality commo...
 
class RDFPMMLUtils overview flow hierarchy // Utility methods related to PMML serialization of random decision forest...
constructor RDFPMMLUtils() logic callers
 
Package com.cloudera.oryx.app.rdf.decision // Supports decisions on features that are used inside a decision tree sco...
 
class CategoricalDecision overview flow hierarchy // Represents a decision over a categorical feature. If the categorical fe...
constructor CategoricalDecision() logic callers
method equals() logic callers
method getActiveCategoryEncodings() logic callers
method getDefaultDecision() logic callers
method getType() logic callers
method hashCode() logic callers
method isPositive() logic callers
method toString() logic callers
 
class Decision overview flow hierarchy // Subclasses represent a binary yes/no positive/negative decision based o...
constructor Decision() logic callers
method getDefaultDecision() logic callers
method getFeatureNumber() logic callers
method getType() logic callers
method isPositive() logic callers
method toString() logic callers
 
class NumericDecision overview flow hierarchy // Represents a decision over a numeric feature. Decisions are defined sim...
constructor NumericDecision() logic callers
method equals() logic callers
method getDefaultDecision() logic callers
method getThreshold() logic callers
method getType() logic callers
method hashCode() logic callers
method isPositive() logic callers
method toString() logic callers
 
Package com.cloudera.oryx.app.rdf.tree // Abstractions representing forests, trees, nodes and paths in decision f...
 
class DecisionForest overview flow hierarchy // An ensemble classifier based on many DecisionTree s.
constructor DecisionForest() logic callers
method getFeatureImportances() logic callers
method getTrees() logic callers
method getWeights() logic callers
method predict() logic callers
method toString() logic callers
method update() logic callers
 
class DecisionNode overview flow hierarchy // Represents an internal node in a DecisionTree , which encapsulates a bi...
constructor DecisionNode() logic callers
method equals() logic callers
method getDecision() logic callers
method getLeft() logic callers
method getRight() logic callers
method hashCode() logic callers
method isTerminal() logic callers
method toString() logic callers
 
class DecisionTree overview flow hierarchy // A decision-tree classifier. Given a set of training Example s, builds a...
constructor DecisionTree() logic callers
method findByID() logic callers
method findTerminal() logic callers
method predict() logic callers
method toString() logic callers
method update() logic callers
 
class TerminalNode overview flow hierarchy // Represents a leaf node in a DecisionTree , which contains a Prediction ...
constructor TerminalNode() logic callers
method equals() logic callers
method getCount() logic callers
method getPrediction() logic callers
method hashCode() logic callers
method isTerminal() logic callers
method toString() logic callers
method update() logic callers
 
interface TreeBasedClassifier overview flow hierarchy // Base interface for decision-tree-based classifiers in this package, whe...
method predict() logic callers
method update() logic callers // Requests that the implementation update its internal state to reflect a...
 
class TreeNode overview flow hierarchy // Implementations of this interface represent nodes in a DecisionTree , w...
constructor TreeNode() logic callers
method getID() logic callers
method isTerminal() logic callers
method toString() logic callers
 
class TreePath overview flow hierarchy // Encapsulates a path from root to a node in the tree.
constructor TreePath() logic callers
method compareTo() logic callers
method equals() logic callers
method extendLeft() logic callers
method extendRight() logic callers
method hashCode() logic callers
method isLeftAt() logic callers
method length() logic callers
method toString() logic callers
 
Package com.cloudera.oryx.app.schema // Encapsulation of basic input schema-related information common to many ...
 
class CategoricalValueEncodings overview flow hierarchy // Encapsulates a two-way mapping between the set of values for one catego...
constructor CategoricalValueEncodings() logic callers
method getCategoryCounts() logic callers
method getEncodingValueMap() logic callers
method getValueCount() logic callers
method getValueEncodingMap() logic callers
method toString() logic callers
 
class InputSchema overview flow hierarchy // Represents the essential schema information needed for some learning pr...
method featureToPredictorIndex() logic callers
method getFeatureNames() logic callers
method getNumFeatures() logic callers
method getNumPredictors() logic callers
method getTargetFeature() logic callers
method getTargetFeatureIndex() logic callers
method hasTarget() logic callers
method isActive() logic callers
method isActive() logic callers
method isCategorical() logic callers
method isCategorical() logic callers
method isClassification() logic callers
method isID() logic callers
method isID() logic callers
method isNumeric() logic callers
method isNumeric() logic callers
method isTarget() logic callers
method isTarget() logic callers
method predictorToFeatureIndex() logic callers
method toString() logic callers
 
Module oryx-app-mllib gh
 
Package com.cloudera.oryx.app.batch.mllib.als // Contains an app tier implementation of a Batch Layer, for ALS recommend...
 
class ALSUpdate overview flow hierarchy // A specialization of MLUpdate that creates a matrix factorization model...
method canPublishAdditionalModelData() logic callers
method getHyperParameterValues() logic callers
method invertMap() logic callers
 
class EnqueueFeatureVecsAndKnownItemsFn overview flow hierarchy
constructor EnqueueFeatureVecsAndKnownItemsFn() logic callers
 
class EnqueueFeatureVecsFn overview flow hierarchy
constructor EnqueueFeatureVecsFn() logic callers
 
class Evaluation overview flow hierarchy // Computes AUC (area under the ROC curve) as a recommender evaluation met...
constructor Evaluation() logic callers
 
Package com.cloudera.oryx.app.batch.mllib.kmeans // Contains an app tier implementation of a Batch Layer, for k-means clust...
 
class AbstractKMeansEvaluation overview flow hierarchy
constructor AbstractKMeansEvaluation() logic callers
method getClustersByID() logic callers
method getDistanceFn() logic callers
 
class ClusterMetric overview flow hierarchy
constructor ClusterMetric() logic callers
method add() logic callers
method getCount() logic callers
method getMeanDist() logic callers
method getSumDist() logic callers
method getSumSquaredDist() logic callers
 
class DaviesBouldinIndex overview flow hierarchy
constructor DaviesBouldinIndex() logic callers
 
class DunnIndex overview flow hierarchy
constructor DunnIndex() logic callers
 
enum KMeansEvalStrategy overview flow hierarchy // Evaluation metrics for k-means clustering.
 
class KMeansUpdate overview flow hierarchy // Update function that builds and evaluates k-means models in the Batch L...
method getHyperParameterValues() logic callers
 
class SilhouetteCoefficient overview flow hierarchy
constructor SilhouetteCoefficient() logic callers
method clusterDissimilarityForPoint() logic callers
method iterableToList() logic callers
method minInterClusterDissimilarityForPoint() logic callers
method silhouetteCoefficient() logic callers
method silhouetteCoefficient() logic callers // Computes the Silhouette Coefficient for this clustering. See https://en...
 
class SumSquaredError overview flow hierarchy
constructor SumSquaredError() logic callers
 
Package com.cloudera.oryx.app.batch.mllib.rdf // Contains an app tier implementation of a Batch Layer, for random decisi...
 
class Evaluation overview flow hierarchy
constructor Evaluation() logic callers
 
class RDFUpdate overview flow hierarchy // Update function that builds and evaluates random decision forest models...
method getHyperParameterValues() logic callers
 
Module oryx-app-serving gh
 
Package com.cloudera.oryx.app.serving // Contains common code supporting several implementations of an app-tier ...
 
class AbstractConsoleResource overview flow hierarchy // Superclass of web resources that contain a small console for a Serving ...
method getConsoleResource() logic callers
method loadHTML() logic callers
 
class AbstractOryxResource overview flow hierarchy // Superclass of all Serving Layer application endpoints.
method check() logic callers
method checkExists() logic callers
method checkNotReadOnly() logic callers
method getServingModel() logic callers
method isReadOnly() logic callers
method maybeBuffer() logic callers
method maybeBuffer() logic callers
method sendInput() logic callers
 
class FileItemPart overview flow hierarchy // Adapter from FileItem to Part , for use in tests while still necessary ...
method delete() logic callers
method getContentType() logic callers
method getHeader() logic callers
method getHeaderNames() logic callers
method getHeaders() logic callers
method getInputStream() logic callers
method getName() logic callers
method getSize() logic callers
method getSubmittedFileName() logic callers
method write() logic callers
 
class IDCount overview flow hierarchy // Encapsulates a String ID and a count.
constructor IDCount() logic callers
constructor IDCount() logic callers
method getCount() logic callers
method valueString() logic callers
 
class IDEntity overview flow hierarchy // Superclass of objects that encapsulate, among other things, a String ID.
constructor IDEntity() logic callers
method getID() logic callers
method toCSV() logic callers
method toString() logic callers
method valueString() logic callers
 
class IDValue overview flow hierarchy // Encapsulates a String ID and a floating-point value.
constructor IDValue() logic callers
constructor IDValue() logic callers
method getValue() logic callers
method valueString() logic callers
 
class Ready overview flow hierarchy // Responds to a HEAD or GET request to /ready and returns Response.Statu...
 
Package com.cloudera.oryx.app.serving.als // Contains an app tier implementation of a Serving Layer, for ALS recomme...
 
class AbstractALSResource overview flow hierarchy // Superclass of all Serving Layer ALS application endpoints.
method checkHowManyOffset() logic callers
method getALSServingModel() logic callers
method toIDValueResponse() logic callers
 
class AllItemIDs overview flow hierarchy // Responds to a GET request to /item/allIDs . CSV output consists of one...
method get() logic callers
 
class AllUserIDs overview flow hierarchy // Responds to a GET request to /user/allIDs . CSV output consists of one...
method get() logic callers
 
class Because overview flow hierarchy // Responds to a GET request to /because/[userID]/[itemID](?howMany=n)(&o...
method get() logic callers
 
class Console overview flow hierarchy // ALS app Serving Layer console.
method getConsoleResource() logic callers
 
class CosineAverageFunction overview flow hierarchy // Computes the cosine of the angle between a target vector and other vect...
constructor CosineAverageFunction() logic callers
constructor CosineAverageFunction() logic callers
method applyAsDouble() logic callers
method getTargetVector() logic callers
 
interface CosineDistanceSensitiveFunction overview flow hierarchy // Implementations of this type of function return a value that depends on...
method getTargetVector() logic callers
 
class DotsFunction overview flow hierarchy // Computes the dot product of a target vector and other vectors.
constructor DotsFunction() logic callers
constructor DotsFunction() logic callers
method applyAsDouble() logic callers
method getTargetVector() logic callers
 
class Estimate overview flow hierarchy // Responds to a GET request to /estimate/[userID]/[itemID] . The results...
 
class EstimateForAnonymous overview flow hierarchy // Responds to a GET request to /estimateForAnonymous/[toItemID]/[itemID1...
method buildTemporaryUserVector() logic callers // Builds a temporary user feature vector given an (optional) existing use...
 
class Ingest overview flow hierarchy // Responds to a POST to /ingest . For each line in the request body, a l...
method doPost() logic callers
method post() logic callers
 
class KnownItems overview flow hierarchy // Responds to a GET request to /knownItems/[userID] . CSV output consist...
method get() logic callers
 
class MostActiveUsers overview flow hierarchy // Responds to a GET request to /mostActiveUsers(?howMany=n)(&offset=o)(&...
method get() logic callers
 
class MostPopularItems overview flow hierarchy // Responds to a GET request to /mostPopularItems(?howMany=n)(&offset=o)(...
method get() logic callers
method mapTopCountsToIDCounts() logic callers
 
class MostSurprising overview flow hierarchy // Responds to a GET request to /mostSurprising/[userID](?howMany=n)(?off...
method get() logic callers
 
class PopularRepresentativeItems overview flow hierarchy // Responds to a GET request to /popularRepresentativeItems . The result ...
method get() logic callers
 
class Preference overview flow hierarchy // Responds to a POST request to /pref/[userID]/[itemID] . The first line...
method delete() logic callers
method post() logic callers
method sendToTopic() logic callers
method validateAndStandardizeStrength() logic callers
 
class Recommend overview flow hierarchy // Responds to a GET request to /recommend/[userID](?howMany=n)(&offset=o...
method get() logic callers
 
class RecommendToAnonymous overview flow hierarchy // Responds to a GET request to /recommendToAnonymous/[itemID1(=value1)](...
 
class RecommendToMany overview flow hierarchy // Responds to a GET request to /recommendToMany/[userID1](/[userID2]/......
 
class RecommendWithContext overview flow hierarchy // Responds to a GET request to /recommendWithContext/[userID]/([itemID1(...
 
class Similarity overview flow hierarchy // Responds to a GET request to /similarity/[itemID1](/[itemID2]/...)(?ho...
 
class SimilarityToItem overview flow hierarchy // Responds to a GET request to /similarityToItem/[toItemID]/[itemID1](/[...
 
Package com.cloudera.oryx.app.serving.als.model // Data model support for the ALS recommender Serving Layer app.
 
class ALSServingModel overview flow hierarchy // Contains all data structures needed to serve real-time requests for an ...
constructor ALSServingModel() logic callers // Creates an empty model.
method addKnownItems() logic callers
method getAllItemIDs() logic callers
method getAllUserIDs() logic callers
method getFeatures() logic callers
method getFractionLoaded() logic callers
method getItemCounts() logic callers
method getItemVector() logic callers
method getKnownItemVectorsForUser() logic callers
method getKnownItems() logic callers
method getNumItems() logic callers
method getNumUsers() logic callers
method getRescorerProvider() logic callers
method getUserCounts() logic callers
method getUserVector() logic callers
method getYTYSolver() logic callers
method isImplicit() logic callers
method precomputeSolvers() logic callers
method retainRecentAndItemIDs() logic callers // Retains only items that are expected to appear in the upcoming model up...
method retainRecentAndKnownItems() logic callers // Like {@link #retainRecentAndUserIDs(Collection)} and {@link #retainRece...
method retainRecentAndUserIDs() logic callers // Retains only users that are expected to appear in the upcoming model up...
method setItemVector() logic callers
method setUserVector() logic callers
method toString() logic callers
method topN() logic callers
 
class ALSServingModelManager overview flow hierarchy // A com.cloudera.oryx.api.serving.ServingModelManager that manages and pr...
method getModel() logic callers
method loadInstanceOf() logic callers
method loadRescorerProviders() logic callers
 
class LocalitySensitiveHash overview flow hierarchy
constructor LocalitySensitiveHash() logic callers
constructor LocalitySensitiveHash() logic callers
method getCandidateIndices() logic callers
method getIndexFor() logic callers
method getMaxBitsDiffering() logic callers
method getNumHashes() logic callers
method getNumPartitions() logic callers
method totalAbsCos() logic callers
 
class TopNConsumer overview flow hierarchy
constructor TopNConsumer() logic callers
method accept() logic callers
method getTopN() logic callers
 
Package com.cloudera.oryx.app.serving.classreg // Contains app tier support code for implementations of classification an...
 
class Predict overview flow hierarchy // Responds to a GET request to /predict/[datum] , or a POST to /predict ...
method doPost() logic callers
method get() logic callers
method post() logic callers
method predict() logic callers
 
class Train overview flow hierarchy // Responds to POST request to /train . The input is one or more data poi...
method doPost() logic callers
method post() logic callers
method post() logic callers
 
Package com.cloudera.oryx.app.serving.classreg.model
 
interface ClassificationRegressionServingModel overview flow hierarchy // Implementations are ServingModel s that specifically support classifica...
method predict() logic callers
 
Package com.cloudera.oryx.app.serving.clustering
 
class Add overview flow hierarchy // Responds to POST request to /add . The input is one or more data point...
method doPost() logic callers
method post() logic callers
method post() logic callers
 
class Assign overview flow hierarchy // Responds to a GET request to /assign/[datum] , or a POST to /assign co...
method doPost() logic callers
method get() logic callers
method nearestClusterID() logic callers
method post() logic callers
 
Package com.cloudera.oryx.app.serving.clustering.model // Contains app tier support code for implementations of clustering in the...
 
interface ClusteringServingModel overview flow hierarchy // Implementations are ServingModel s that specifically support clustering...
method nearestClusterID() logic callers
 
Package com.cloudera.oryx.app.serving.kmeans // Contains an app tier implementation of a Serving Layer, for k-means clu...
 
class Console overview flow hierarchy // k-means app Serving Layer console.
method getConsoleResource() logic callers
 
class DistanceToNearest overview flow hierarchy // Responds to a GET request to /distanceToNearest/[datum] . The inputs i...
method get() logic callers
 
Package com.cloudera.oryx.app.serving.kmeans.model // Data model support for the k-means clustering Serving Layer app.
 
class KMeansServingModel overview flow hierarchy // Contains all data structures needed to serve queries for a k-means clus...
constructor KMeansServingModel() logic callers
method closestCluster() logic callers
method getCluster() logic callers
method getFractionLoaded() logic callers
method getInputSchema() logic callers
method getNumClusters() logic callers
method nearestClusterID() logic callers
method toString() logic callers
method update() logic callers
 
class KMeansServingModelManager overview flow hierarchy // A com.cloudera.oryx.api.serving.ServingModelManager that manages and pr...
method getModel() logic callers
 
Package com.cloudera.oryx.app.serving.rdf // Contains an app tier implementation of a Serving Layer, for random deci...
 
class ClassificationDistribution overview flow hierarchy // Responds to a GET request to /classificationDistribution/[datum] . Lik...
method get() logic callers
 
class Console overview flow hierarchy // Random decision forest app Serving Layer console.
method getConsoleResource() logic callers
 
class FeatureImportance overview flow hierarchy // Responds to a GET request to /feature/importance or /feature/importanc...
method getAllImportances() logic callers
method getImportance() logic callers
 
Package com.cloudera.oryx.app.serving.rdf.model // Data model support for the random decision forest Serving Layer app.
 
class RDFServingModel overview flow hierarchy // Contains all data structures needed to serve queries for a random decis...
constructor RDFServingModel() logic callers
method getEncodings() logic callers
method getForest() logic callers
method getFractionLoaded() logic callers
method getInputSchema() logic callers
method makePrediction() logic callers
method predict() logic callers
method toString() logic callers
 
class RDFServingModelManager overview flow hierarchy // A com.cloudera.oryx.api.serving.ServingModelManager that manages and pr...
method getModel() logic callers
 
Module oryx-batch gh
 
Package com.cloudera.oryx.batch // Contains the actual Batch Layer packaged application.
 
class Main overview flow hierarchy // Runs BatchLayer from the command line. It will use configuration as loa...
constructor Main() logic callers
method main() logic callers Java Main Methods
 
Module oryx-common gh
 
Package com.cloudera.oryx.common.collection // Collection-related utility methods and support classes.
 
interface CloseableIterator overview flow hierarchy // Implementations are Iterator s that are also Closeable .
method close() logic callers
 
class Pair overview flow hierarchy // Encapsulates a pair of objects.
constructor Pair() logic callers
constructor Pair() logic callers
constructor Pair() logic callers
constructor Pair() logic callers
constructor Pair() logic callers
constructor Pair() logic callers
method equals() logic callers
method getFirst() logic callers
method getSecond() logic callers
method hashCode() logic callers
method toString() logic callers
 
class Pairs overview flow hierarchy // Pair -related utilities.
constructor Pairs() logic callers
method orderByFirst() logic callers
method orderBySecond() logic callers
 
Package com.cloudera.oryx.common.io // Utility code and methods on top of Java's I/O packages that relate to i...
 
class IOUtils overview flow hierarchy // I/O-related utility methods.
constructor IOUtils() logic callers
method chooseFreePort() logic callers // Binds to a free ephemeral port, and then releases it. The returned port...
method closeQuietly() logic callers // Closes a {@link Closeable} and logs the exception, if any. This is only...
method deleteRecursively() logic callers // Deletes the given path, and if it is a directory, all files and subdire...
method listFiles() logic callers
 
Package com.cloudera.oryx.common.lang // Contains utility code related to the JVM, classes, logging and other co...
 
class AutoLock overview flow hierarchy // Makes a Lock into an AutoCloseable for use with try-with-resources: Loc...
constructor AutoLock() logic callers // Manages a new {@link ReentrantLock}.
constructor AutoLock() logic callers
method autoLock() logic callers
method close() logic callers // Unlocks the underlying {@link Lock}.
method lock() logic callers
method lockInterruptibly() logic callers
method newCondition() logic callers
method toString() logic callers
method tryLock() logic callers
method tryLock() logic callers
method unlock() logic callers
 
class AutoReadWriteLock overview flow hierarchy // Makes a ReadWriteLock that can return AutoLock s and exposes #autoReadL...
constructor AutoReadWriteLock() logic callers
constructor AutoReadWriteLock() logic callers // Manages a new {@link ReentrantReadWriteLock}.
method autoReadLock() logic callers
method autoWriteLock() logic callers
method readLock() logic callers
method toString() logic callers
method writeLock() logic callers
 
class ClassUtils overview flow hierarchy // Class -related utility methods.
constructor ClassUtils() logic callers
method classExists() logic callers
method forName() logic callers
method loadClass() logic callers
method loadClass() logic callers
method loadInstanceOf() logic callers
method loadInstanceOf() logic callers // Like {@link #loadInstanceOf(String,Class)} where the reference returned...
method loadInstanceOf() logic callers // Like {@link #loadInstanceOf(String,Class,Class[],Object[])} for no-arg ...
method loadInstanceOf() logic callers // Loads and instantiates a named implementation class, a subclass of a gi...
 
class ExecUtils overview flow hierarchy // Utility methods for executing tasks in parallel, possibly returning a r...
constructor ExecUtils() logic callers
method collectInParallel() logic callers
method doInParallel() logic callers
method doInParallel() logic callers
 
class JVMUtils overview flow hierarchy // JVM-related utility methods.
constructor JVMUtils() logic callers
method closeAtShutdown() logic callers // Adds a shutdown hook that tries to call {@link Closeable#close()} on th...
method getUsedMemory() logic callers
 
class LoggingCallable overview flow hierarchy // A Callable that logs errors thrown from #call() . Useful in cases where...
constructor LoggingCallable() logic callers
method asRunnable() logic callers
method call() logic callers
method log() logic callers
method log() logic callers
 
class OryxShutdownHook overview flow hierarchy // Intended for use with Runtime#addShutdownHook(Thread) or similar mechan...
constructor OryxShutdownHook() logic callers
method addCloseable() logic callers
method run() logic callers
 
class RateLimitCheck overview flow hierarchy // A utility that exposes a #test() method which returns true first, and t...
constructor RateLimitCheck() logic callers
method test() logic callers
 
interface ToDoubleObjDoubleBiFunction overview flow hierarchy // Analogous to both java.util.function.ToDoubleBiFunction and java.util.f...
method applyAsDouble() logic callers
method applyAsDouble() logic callers // Applies this function to the given arguments.
 
Package com.cloudera.oryx.common.math // General mathematical functions and related support code, including basi...
 
class DoubleWeightedMean overview flow hierarchy // A weighted mean implementation for floating-point weights, following t...
constructor DoubleWeightedMean() logic callers
constructor DoubleWeightedMean() logic callers
method clear() logic callers
method copy() logic callers
method equals() logic callers
method getN() logic callers
method getResult() logic callers
method hashCode() logic callers
method increment() logic callers
method increment() logic callers
method toString() logic callers
 
class LinearSystemSolver overview flow hierarchy // An implementation based on RRQRDecomposition from Commons Math.
constructor LinearSystemSolver() logic callers
method getSolver() logic callers
method getSolver() logic callers
 
class SingularMatrixSolverException overview flow hierarchy // Throws when a system can't be solved because the input matrix is singul...
constructor SingularMatrixSolverException() logic callers
method getApparentRank() logic callers
 
class Solver overview flow hierarchy // Encapsulates a DecompositionSolver from Commons Math.
method solveDToD() logic callers
method solveFToF() logic callers
method toString() logic callers
 
class VectorMath overview flow hierarchy // Utility class with simple vector-related operations.
constructor VectorMath() logic callers
method cosineSimilarity() logic callers // Computes cosine similarity of values in two given arrays, when the norm...
method dot() logic callers
method norm() logic callers
method norm() logic callers
method parseVector() logic callers
method randomVectorF() logic callers
method transposeTimesSelf() logic callers
 
Package com.cloudera.oryx.common.pmml // Utility code related to parsing, writing and manipulating PMML represen...
 
class PMMLUtils overview flow hierarchy // PMML-related utility methods.
constructor PMMLUtils() logic callers
 
Package com.cloudera.oryx.common.random // Utility code related to generating randomness and managing random state.
 
class RandomManager overview flow hierarchy // Manages random number generation. Allows resetting RNGs to a known stat...
constructor RandomManager() logic callers
method getRandom() logic callers
method getTestSeed() logic callers
method useTestSeed() logic callers // <em>Only call in test code.</em> Causes all known instances of {@link R...
 
Package com.cloudera.oryx.common.settings // Utility code pertaining to application configuration management.
 
class ConfigToProperties overview flow hierarchy // Utility that outputs all configuration as key-value pairs (as in a .pro...
constructor ConfigToProperties() logic callers
method buildPropertiesLines() logic callers
method main() logic callers Java Main Methods
 
class ConfigUtils overview flow hierarchy // Utilities for retrieving Config instances.
constructor ConfigUtils() logic callers
method getDefault() logic callers
method keyValueToProperties() logic callers
method redact() logic callers
method set() logic callers // Helper to set a {@link Path} value correctly for use with {@link #overl...
 
Package com.cloudera.oryx.common.text // Contains simple utility functions related to text parsing and formatting.
 
class TextUtils overview flow hierarchy // Text and parsing related utility methods.
constructor TextUtils() logic callers
method convertViaJSON() logic callers
method joinDelimited() logic callers
method joinJSON() logic callers
method joinPMMLDelimited() logic callers
method joinPMMLDelimitedNumbers() logic callers
method parseDelimited() logic callers
method parseJSONArray() logic callers
method parsePMMLDelimited() logic callers
method readJSON() logic callers
 
Module oryx-lambda gh
 
Package com.cloudera.oryx.lambda // Code used across the Lambda tier.
 
class AbstractSparkLayer overview flow hierarchy // Encapsulates commonality between Spark-based layer processes, com.cloud...
method getConfigGroup() logic callers
method getGroupID() logic callers
method getID() logic callers
method getInputTopicLockMaster() logic callers
method getKeyClass() logic callers
method getLayerName() logic callers
method getMessageClass() logic callers
 
class DeleteOldDataFn overview flow hierarchy // Function that deletes old data, if applicable, at each batch interval.
method call() logic callers
 
class HadoopUtils overview flow hierarchy // Hadoop-related utility methods.
constructor HadoopUtils() logic callers
method closeAtShutdown() logic callers // Adds a shutdown hook that tries to call {@link Closeable#close()} on th...
 
class TopicProducerImpl overview flow hierarchy // Wraps access to a Kafka message topic Producer .
constructor TopicProducerImpl() logic callers
method close() logic callers
method getTopic() logic callers
method getUpdateBroker() logic callers
method send() logic callers
 
class UpdateOffsetsFn overview flow hierarchy // Function that reads offset range from latest RDD in a streaming job, an...
constructor UpdateOffsetsFn() logic callers
 
Package com.cloudera.oryx.lambda.batch // Contains the core support for the Lambda tier of the Batch Layers. This...
 
class BatchLayer overview flow hierarchy // Main entry point for Oryx Batch Layer.
method await() logic callers
method close() logic callers
method getConfigGroup() logic callers
method getLayerName() logic callers
method loadUpdateInstance() logic callers
method start() logic callers
 
class BatchUpdateFunction overview flow hierarchy // Framework for executing the batch layer update, and storing data to per...
 
class SaveToHDFSFunction overview flow hierarchy // Function that saves RDDs to HDFS -- only if they're non empty, to preve...
 
class ScalaBatchLayerUpdateAdapter overview flow hierarchy // Adapts a ScalaBatchLayerUpdate to be a Java BatchLayerUpdate .
 
class ValueToWritableFunction overview flow hierarchy // Translates a key and message value object into Writable s encapsulating...
method initConverters() logic callers
method readObject() logic callers
 
class ValueWritableConverter overview flow hierarchy // Utility class that automatically converts a value object to and from a ...
constructor ValueWritableConverter() logic callers
method static() logic callers
 
class WritableToValueFunction overview flow hierarchy // Translates a key and message in Writable s format to value objects.
method initConverters() logic callers
method readObject() logic callers
 
Package com.cloudera.oryx.lambda.speed // Contains the core support for the Lambda tier of the Speed Layers.
 
class ScalaSpeedModelManagerAdapter overview flow hierarchy // Adapts a ScalaSpeedModelManager to be a Java SpeedModelManager .
method close() logic callers
 
class SpeedLayer overview flow hierarchy // Main entry point for Oryx Speed Layer.
method await() logic callers
method close() logic callers
method getConfigGroup() logic callers
method getLayerName() logic callers
method loadManagerInstance() logic callers
method start() logic callers
 
class SpeedLayerUpdate overview flow hierarchy // Main Spark Streaming function for the speed layer that collects and pub...
constructor SpeedLayerUpdate() logic callers
 
Module oryx-lambda-serving gh
 
Package com.cloudera.oryx.lambda.serving // Contains the core support for the Lambda tier of the Serving Layers.
 
class CSVMessageBodyWriter overview flow hierarchy // A MessageBodyWriter that can produce CSV ( text/csv ). If given an Iter...
method toCSV() logic callers
 
class ErrorResource overview flow hierarchy // Constructs a simple HTML error page from error info in the request. Thi...
 
class InMemoryRealm overview flow hierarchy // Adapted from Tomcat's org.apache.catalina.realm.MemoryRealm . This impl...
method addUser() logic callers
method authenticate() logic callers
method getPassword() logic callers
method getPrincipal() logic callers
 
class ModelManagerListener overview flow hierarchy // ServletContextListener that initializes a ServingModelManager at webap...
method close() logic callers
method loadManagerInstance() logic callers
 
class OryxApplication overview flow hierarchy // The single JAX-RS app for the serving-layer.
method doGetClasses() logic callers
method getClasses() logic callers
 
class OryxExceptionMapper overview flow hierarchy // Maps OryxServingException types to an HTTP Response .
 
class ScalaServingModelManagerAdapter overview flow hierarchy // Adapts a ScalaServingModelManager to be a Java ServingModelManager .
method close() logic callers
method getModel() logic callers
method isReadOnly() logic callers
 
class ServingLayer overview flow hierarchy // Top-level implementation of the Serving Layer process.
method await() logic callers // Blocks and waits until the server shuts down.
method close() logic callers
method start() logic callers
 
class TopicProducerImpl overview flow hierarchy // Wraps access to a Kafka message topic Producer .
constructor TopicProducerImpl() logic callers
method close() logic callers
method getTopic() logic callers
method getUpdateBroker() logic callers
method send() logic callers
 
Module oryx-ml gh
 
Package com.cloudera.oryx.ml // Contains the core support for the ML tier of the Batch and Speed layers.
 
class MLUpdate overview flow hierarchy // A specialization of BatchLayerUpdate for machine learning-orientedupdat...
method canPublishAdditionalModelData() logic callers
method getHyperParameterValues() logic callers
method getTestFraction() logic callers
 
Package com.cloudera.oryx.ml.param // This package supports defining hyperparameter ranges and selecting comb...
 
class ContinuousAround overview flow hierarchy
constructor ContinuousAround() logic callers
method getNumDistinctValues() logic callers
method getTrialValues() logic callers
method toString() logic callers
 
class ContinuousRange overview flow hierarchy
constructor ContinuousRange() logic callers
method getNumDistinctValues() logic callers
method getTrialValues() logic callers
method toString() logic callers
 
class DiscreteAround overview flow hierarchy
constructor DiscreteAround() logic callers
method getNumDistinctValues() logic callers
method getTrialValues() logic callers
method toString() logic callers
 
class DiscreteRange overview flow hierarchy
constructor DiscreteRange() logic callers
method getNumDistinctValues() logic callers
method getTrialValues() logic callers
method toString() logic callers
 
class GridSearch overview flow hierarchy
constructor GridSearch() logic callers
method chooseHyperParameterCombos() logic callers
method chooseValuesPerHyperParam() logic callers
 
interface HyperParamValues overview flow hierarchy // Encapsulates a range or set of values for a hyperparameter, from which ...
method getNumDistinctValues() logic callers
method getRandomValue() logic callers
method getTrialValues() logic callers
method getTrialValues() logic callers
 
class HyperParams overview flow hierarchy // Utility methods related to expressing and selecting hyperparameter valu...
constructor HyperParams() logic callers
method around() logic callers
method around() logic callers
method chooseHyperParameterCombos() logic callers
method fixed() logic callers
method fixed() logic callers
method range() logic callers
method range() logic callers
method unorderedFromValues() logic callers
 
class RandomSearch overview flow hierarchy
constructor RandomSearch() logic callers
method chooseHyperParameterCombos() logic callers
 
class Unordered overview flow hierarchy
constructor Unordered() logic callers
method getNumDistinctValues() logic callers
method getTrialValues() logic callers
method toString() logic callers
 
Module oryx-serving gh
 
Package com.cloudera.oryx.serving // Contains the actual Serving Layer packaged application.
 
class Main overview flow hierarchy // Runs ServingLayer from the command line. It will use configuration as l...
constructor Main() logic callers
method main() logic callers Java Main Methods
 
Module oryx-speed gh
 
Package com.cloudera.oryx.speed // Contains the actual Speed Layer packaged application.
 
class Main overview flow hierarchy // Runs SpeedLayer from the command line. It will use configuration as loa...
constructor Main() logic callers
method main() logic callers Java Main Methods