public static class Summary2.PrePass extends MRTask2<Summary2.PrePass>
Modifier and Type | Field and Description |
---|---|
Summary2.BasicStat[] |
_basicStats |
_appendables, _fr, _fs, _hi, _left, _lo, _nhi, _nleft, _nrite, _nxx, _rite, _t0, _topLocal
_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth
Constructor and Description |
---|
Summary2.PrePass() |
Modifier and Type | Method and Description |
---|---|
Summary2.PrePass |
finishUp() |
void |
map(Chunk[] cs)
Override with your map implementation.
|
void |
reduce(Summary2.PrePass other)
Override to combine results from 'mrt' into 'this' MRTask2.
|
asyncExec, asyncExec, asyncExec, block, clone, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, exec, exec, exec, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, priority, profString, reduce4, setupLocal, vecs
copyOver, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFields
compute
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 Summary2.BasicStat[] _basicStats
public void map(Chunk[] cs)
MRTask2
map
in class MRTask2<Summary2.PrePass>
public void reduce(Summary2.PrePass other)
MRTask2
reduce
in class MRTask2<Summary2.PrePass>
public Summary2.PrePass finishUp()