public class ChunkSummary extends MRTask<ChunkSummary>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nlo, _nrite, _rite, _run_local, _topLocal
_ex, _modifiesInputs
Constructor and Description |
---|
ChunkSummary() |
Modifier and Type | Method and Description |
---|---|
void |
map(Chunk[] cs)
Override with your map implementation.
|
protected void |
postGlobal() |
void |
reduce(ChunkSummary mrt)
Override to combine results from 'mrt' into 'this' MRTask.
|
java.lang.String |
toString() |
TwoDimTable |
toTwoDimTableChunkTypes() |
TwoDimTable |
toTwoDimTableDistribution() |
appendables, asyncExec, asyncExec, asyncExec, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, 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, postLocal, priority, profString, self, setProfile, setupLocal
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 void map(Chunk[] cs)
MRTask
map
in class MRTask<ChunkSummary>
public void reduce(ChunkSummary mrt)
MRTask
reduce
in class MRTask<ChunkSummary>
protected void postGlobal()
postGlobal
in class MRTask<ChunkSummary>
public TwoDimTable toTwoDimTableChunkTypes()
public TwoDimTable toTwoDimTableDistribution()
public java.lang.String toString()
toString
in class java.lang.Object