public static class GLMTask.GLMGenerateWeightsTask extends water.MRTask<GLMTask.GLMGenerateWeightsTask>
Constructor and Description |
---|
GLMTask.GLMGenerateWeightsTask(water.Key jobKey,
DataInfo dinfo,
GLMModel.GLMParameters glm,
double[] betaw) |
Modifier and Type | Method and Description |
---|---|
void |
map(water.fvec.Chunk[] chunks) |
void |
reduce(GLMTask.GLMGenerateWeightsTask git) |
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
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.GLMGenerateWeightsTask(water.Key jobKey, DataInfo dinfo, GLMModel.GLMParameters glm, double[] betaw)
public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.GLMGenerateWeightsTask>
public void reduce(GLMTask.GLMGenerateWeightsTask git)
reduce
in class water.MRTask<GLMTask.GLMGenerateWeightsTask>