public static class Gram.GramTask extends FrameTask<Gram.GramTask>
Modifier and Type | Field and Description |
---|---|
Gram |
_gram |
long |
_nobs |
_dinfo, _jobKey, _shuffle, _useFraction
Constructor and Description |
---|
Gram.GramTask(water.Key jobKey,
DataInfo dinfo) |
Modifier and Type | Method and Description |
---|---|
protected void |
chunkDone(long n)
Override this to do post-chunk processing work.
|
protected void |
chunkInit()
Override this to initialize at the beginning of chunk processing.
|
protected void |
processRow(long gid,
DataInfo.Row r)
Method to process one row of the data for GLM functions.
|
void |
reduce(Gram.GramTask gt) |
closeLocal, dfork, dinfo, map, processRow, setupLocal
appendables, asyncExec, asyncExec, asyncExec, block, compute2, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, outputFrame, postGlobal, priority, profString, setProfile
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
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 Gram _gram
public long _nobs
public Gram.GramTask(water.Key jobKey, DataInfo dinfo)
protected void chunkInit()
FrameTask
chunkInit
in class FrameTask<Gram.GramTask>
protected void processRow(long gid, DataInfo.Row r)
FrameTask
processRow
in class FrameTask<Gram.GramTask>
gid
- - global id of this row, in [0,_adaptedFrame.numRows())protected void chunkDone(long n)
FrameTask
chunkDone
in class FrameTask<Gram.GramTask>
n
- Number of processed rowspublic void reduce(Gram.GramTask gt)
reduce
in class water.MRTask<Gram.GramTask>