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