hex.tree.drf

Class TreeMeasuresCollector

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask<TreeMeasuresCollector>

hex.tree.drf.TreeMeasuresCollector

All Implemented Interfaces:

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

public class TreeMeasuresCollector
extends water.MRTask<TreeMeasuresCollector>

Score given tree model and preserve errors per tree in form of votes (for classification) or MSE (for regression). This is different from Model.score() function since the MR task uses inverse loop: first over all trees and over all rows in chunk.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TreeMeasuresCollector.ShuffleTask
static class	TreeMeasuresCollector.TreeMeasures<T extends TreeMeasuresCollector.TreeMeasures> A simple holder for set of different tree measurements.
static class	TreeMeasuresCollector.TreeSSE A simple holder serving SSE per tree.
static class	TreeMeasuresCollector.TreeVotes A class holding tree votes.

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 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

Method Summary

Methods

Modifier and Type	Method and Description
static TreeMeasuresCollector.TreeSSE	asSSE(TreeMeasuresCollector.TreeMeasures tm)
static TreeMeasuresCollector.TreeVotes	asVotes(TreeMeasuresCollector.TreeMeasures tm)
static TreeMeasuresCollector.TreeSSE	collectSSE(CompressedTree[] tree, int nclasses, water.fvec.Frame f, int ncols, float rate, int variable, double threshold, SharedTree st)
static TreeMeasuresCollector.TreeVotes	collectVotes(CompressedTree[] tree, int nclasses, water.fvec.Frame f, int ncols, float rate, int variable, double threshold, SharedTree st)
void	map(water.fvec.Chunk[] chks)
void	reduce(TreeMeasuresCollector t)
TreeMeasuresCollector.TreeSSE	resultSSE()
TreeMeasuresCollector.TreeVotes	resultVotes()

Methods inherited from class water.MRTask

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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, self, setupLocal

Methods inherited from class water.DTask

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

Methods inherited from class water.H2O.H2OCountedCompleter

asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON

Methods inherited from class jsr166y.CountedCompleter

__tryComplete, 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

Method Detail

map

public void map(water.fvec.Chunk[] chks)

Overrides:

map in class water.MRTask<TreeMeasuresCollector>

reduce

public void reduce(TreeMeasuresCollector t)

Overrides:

reduce in class water.MRTask<TreeMeasuresCollector>

resultVotes

public TreeMeasuresCollector.TreeVotes resultVotes()

resultSSE

public TreeMeasuresCollector.TreeSSE resultSSE()

collectVotes

public static TreeMeasuresCollector.TreeVotes collectVotes(CompressedTree[] tree,
                                           int nclasses,
                                           water.fvec.Frame f,
                                           int ncols,
                                           float rate,
                                           int variable,
                                           double threshold,
                                           SharedTree st)

collectSSE

public static TreeMeasuresCollector.TreeSSE collectSSE(CompressedTree[] tree,
                                       int nclasses,
                                       water.fvec.Frame f,
                                       int ncols,
                                       float rate,
                                       int variable,
                                       double threshold,
                                       SharedTree st)

asVotes

public static TreeMeasuresCollector.TreeVotes asVotes(TreeMeasuresCollector.TreeMeasures tm)

asSSE

public static TreeMeasuresCollector.TreeSSE asSSE(TreeMeasuresCollector.TreeMeasures tm)