public static class GLMTask.ComputeSETsk extends FrameTask2<GLMTask.ComputeSETsk>
_dinfo, _sparse
Constructor and Description |
---|
GLMTask.ComputeSETsk(water.H2O.H2OCountedCompleter cmp,
DataInfo dinfo,
water.Key jobKey,
double[] betaNew,
GLMModel.GLMParameters parms) |
Modifier and Type | Method and Description |
---|---|
void |
chunkInit()
Initialization method, called once per "chunk".
|
protected void |
processRow(DataInfo.Row r) |
void |
reduce(GLMTask.ComputeSETsk c) |
chunkDone, handlesSparseData, map, setSparse, 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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, 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
public GLMTask.ComputeSETsk(water.H2O.H2OCountedCompleter cmp, DataInfo dinfo, water.Key jobKey, double[] betaNew, GLMModel.GLMParameters parms)
public void chunkInit()
FrameTask2
chunkInit
in class FrameTask2<GLMTask.ComputeSETsk>
protected void processRow(DataInfo.Row r)
processRow
in class FrameTask2<GLMTask.ComputeSETsk>
public void reduce(GLMTask.ComputeSETsk c)
reduce
in class water.MRTask<GLMTask.ComputeSETsk>