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, self
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, 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, tryUnfork
protected 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)