public class ScoreDTTask extends water.MRTask<ScoreDTTask>
Constructor and Description |
---|
ScoreDTTask(DTModel _model) |
Modifier and Type | Method and Description |
---|---|
hex.ModelMetrics.MetricBuilder |
getMetricsBuilder() |
void |
map(water.fvec.Chunk[] cs) |
void |
reduce(ScoreDTTask other) |
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, setupLocal, 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
public ScoreDTTask(DTModel _model)
public void map(water.fvec.Chunk[] cs)
map
in class water.MRTask<ScoreDTTask>
public void reduce(ScoreDTTask other)
reduce
in class water.MRTask<ScoreDTTask>
public hex.ModelMetrics.MetricBuilder getMetricsBuilder()