public static class LinearAlgebraUtils.BMulTask extends FrameTask<LinearAlgebraUtils.BMulTask>
FrameTask.ExtractDenseRow
Constructor and Description |
---|
LinearAlgebraUtils.BMulTask(water.Key<water.Job> jobKey,
DataInfo dinfo,
double[][] yt) |
Modifier and Type | Method and Description |
---|---|
protected void |
processRow(long gid,
DataInfo.Row row,
water.fvec.NewChunk[] outputs) |
chunkDone, chunkInit, closeLocal, dinfo, getMiniBatchSize, map, processMiniBatch, processRow, processRow, setupLocal
appendables, asyncExecOnAllNodes, block, 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, reduce, 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 LinearAlgebraUtils.BMulTask(water.Key<water.Job> jobKey, DataInfo dinfo, double[][] yt)
protected void processRow(long gid, DataInfo.Row row, water.fvec.NewChunk[] outputs)
processRow
in class FrameTask<LinearAlgebraUtils.BMulTask>