hex.tree

Class DTreeScorer<T extends DTreeScorer<T>>

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask<T>

hex.tree.DTreeScorer<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, jsr166y.ForkJoinPool.ManagedBlocker, water.Freezable

Direct Known Subclasses:

ResidualsCollector

public abstract class DTreeScorer<T extends DTreeScorer<T>>
extends water.MRTask<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.DTask

water.DTask.DKeyTask<T extends water.DTask.DKeyTask,V extends water.Keyed>, water.DTask.RemoveCall

Field Summary

Fields

Modifier and Type	Field and Description
protected int	_nclass
protected int	_ncols
protected int	_skip
protected water.Key[][]	_treeKeys
protected CompressedTree[][]	_trees

Fields inherited from class water.MRTask

_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nlo, _nrite, _rite, _run_local, _topLocal

Fields inherited from class water.DTask

_ex, _modifiesInputs

Constructor Summary

Constructors

Constructor and Description
DTreeScorer(int ncols, int nclass, int skip, water.Key[][] treeKeys)

Method Summary

Methods

Modifier and Type	Method and Description
water.fvec.Chunk	chk_oobt(water.fvec.Chunk[] chks)
water.fvec.Chunk	chk_resp(water.fvec.Chunk[] chks)
water.fvec.Chunk	chk_tree(water.fvec.Chunk[] chks, int c)
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()

Methods inherited from class water.MRTask

appendables, asyncExec, asyncExec, asyncExec, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, postLocal, priority, profString, reduce, self, setProfile

Methods inherited from class water.DTask

copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException

Methods inherited from class water.H2O.H2OCountedCompleter

clone, compute, frozenType, icer, nextThrPriority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Methods inherited from class jsr166y.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

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

Methods inherited from class java.lang.Object

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

Field Detail

_ncols

protected final int _ncols

_nclass

protected final int _nclass

_skip

protected final int _skip

_treeKeys

protected final water.Key[][] _treeKeys

_trees

protected transient CompressedTree[][] _trees

Constructor Detail

DTreeScorer

public DTreeScorer(int ncols,
           int nclass,
           int skip,
           water.Key[][] treeKeys)

Method Detail

ntrees

protected int ntrees()

setupLocal

protected final void setupLocal()

Overrides:

setupLocal in class water.MRTask<T extends DTreeScorer<T>>

chk_oobt

public final water.fvec.Chunk chk_oobt(water.fvec.Chunk[] chks)

chk_tree

public final water.fvec.Chunk chk_tree(water.fvec.Chunk[] chks,
                        int c)

chk_resp

public final water.fvec.Chunk chk_resp(water.fvec.Chunk[] chks)

score0

protected void score0(double[] data,
          double[] preds,
          CompressedTree[] ts)

scoreTree

public static void scoreTree(double[] data,
             double[] preds,
             CompressedTree[] ts)

Score given tree on the row of data.

Parameters:

data - row of data

preds - array to hold resulting prediction

ts - a tree representation (single regression tree, or multi tree)