com.cloudera.oryx.app.als

Class SolverCache

java.lang.Object

com.cloudera.oryx.app.als.SolverCache

public final class SolverCache
extends Object

A cache around a Solver that manages computing it when necessary from FeatureVectors, tracking when it must be recomputed, and doing so correctly in the presence of multiple threads.

Constructor Summary

Constructors

Constructor and Description
SolverCache(Executor executor, FeatureVectors vectorPartitions)

Method Summary

Modifier and Type	Method and Description
void	compute() Proactively try to compute the solver asynchronously, if not already computed.
Solver	get(boolean blocking)
void	setDirty() Indicates that the underlying FeatureVectors have changed and so the resulting Solver should be recomputed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SolverCache

public SolverCache(Executor executor,
                   FeatureVectors vectorPartitions)

Parameters:

executor - Executor which should be used to asynchronously compute a Solver. Important: this should be able to execute more than 1 task in parallel.

vectorPartitions - underling FeatureVectors data from which it should be computed

Method Detail

setDirty

public void setDirty()

Indicates that the underlying FeatureVectors have changed and so the resulting Solver should be recomputed.

compute

public void compute()

Proactively try to compute the solver asynchronously, if not already computed. Does not block.

get

public Solver get(boolean blocking)

Parameters:

blocking - whether to block waiting for a first model

Returns:

a recent Solver, optionally blocking if necessary to wait for an initial one to be computed. It does not block otherwise and returns the most recently computed one. Note that this method may return null even when blocking , for instance, if no solver is computable because there is no data.