public class TreeMeasuresCollector extends water.MRTask<TreeMeasuresCollector>
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.
|
Modifier and Type | Method and Description |
---|---|
static TreeMeasuresCollector.TreeSSE |
asSSE(TreeMeasuresCollector.TreeMeasures tm) |
static TreeMeasuresCollector.TreeVotes |
asVotes(TreeMeasuresCollector.TreeMeasures tm) |
void |
map(water.fvec.Chunk[] chks) |
void |
reduce(TreeMeasuresCollector t) |
TreeMeasuresCollector.TreeSSE |
resultSSE() |
TreeMeasuresCollector.TreeVotes |
resultVotes() |
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, self, withPostMapAction
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, 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 void setupLocal()
setupLocal
in class water.MRTask<TreeMeasuresCollector>
public void map(water.fvec.Chunk[] chks)
map
in class water.MRTask<TreeMeasuresCollector>
public void reduce(TreeMeasuresCollector t)
reduce
in class water.MRTask<TreeMeasuresCollector>
public TreeMeasuresCollector.TreeVotes resultVotes()
public TreeMeasuresCollector.TreeSSE resultSSE()
public static TreeMeasuresCollector.TreeVotes asVotes(TreeMeasuresCollector.TreeMeasures tm)
public static TreeMeasuresCollector.TreeSSE asSSE(TreeMeasuresCollector.TreeMeasures tm)