public abstract class DTreeScorer<T extends DTreeScorer<T>>
extends water.MRTask<T>
| Modifier and Type | Field and Description |
|---|---|
protected int |
_nclass |
protected int |
_ncols |
protected int |
_skip |
protected SharedTree |
_st |
protected water.Key[][] |
_treeKeys |
protected CompressedTree[][] |
_trees |
| Constructor and Description |
|---|
DTreeScorer(int ncols,
int nclass,
SharedTree st,
water.Key[][] treeKeys) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
ntrees() |
protected void |
score0(double[] data,
double[] preds,
CompressedTree[] ts) |
static void |
scoreTree(double[] data,
double[] preds,
CompressedTree[] ts)
Score given tree on the row of data.
|
protected void |
setupLocal() |
appendables, asyncExecOnAllNodes, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, reduce, selfcopyOver, getDException, hasException, logVerbose, onAck, onAckAck, setExceptionasBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryCompleteadapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnforkprotected final int _ncols
protected final int _nclass
protected final int _skip
protected final water.Key[][] _treeKeys
protected transient CompressedTree[][] _trees
protected SharedTree _st
public DTreeScorer(int ncols,
int nclass,
SharedTree st,
water.Key[][] treeKeys)
protected int ntrees()
protected final void setupLocal()
setupLocal in class water.MRTask<T extends DTreeScorer<T>>protected void score0(double[] data,
double[] preds,
CompressedTree[] ts)
public static void scoreTree(double[] data,
double[] preds,
CompressedTree[] ts)
data - row of datapreds - array to hold resulting predictionts - a tree representation (single regression tree, or multi tree)