public static class GuessSetup.GuessSetupTsk extends MRTask<GuessSetup.GuessSetupTsk>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Iced>
Modifier and Type | Field and Description |
---|---|
CustomParser.PSetupGuess |
_gSetup |
static int |
MAX_ERRORS |
_hi, _lo, _runSingleThreaded
_fs, _is_local, _keys, _top_level
Constructor and Description |
---|
GuessSetup.GuessSetupTsk(CustomParser.ParserSetup userSetup,
boolean checkHeader) |
Modifier and Type | Method and Description |
---|---|
void |
map(Key key)
Run some useful function over this local key, and
record the results in the this MRTask.
|
void |
reduce(GuessSetup.GuessSetupTsk drt) |
hi, init, lcompute, lo, lonCompletion, memOverheadPerChunk, onExceptionalCompletion
alsoBlockFor, alsoBlockFor, block, clone, compute2, dfork, getFutures, invoke, invokeOnAllNodes, isReleasable, keys, onCompletion, postGlobal, reduceAlsoBlock
copyOver, dinvoke, 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 CustomParser.PSetupGuess _gSetup
public static final int MAX_ERRORS
public GuessSetup.GuessSetupTsk(CustomParser.ParserSetup userSetup, boolean checkHeader)
public void map(Key key)
MRTask
map
in class MRTask<GuessSetup.GuessSetupTsk>
public void reduce(GuessSetup.GuessSetupTsk drt)
reduce
in class DRemoteTask<GuessSetup.GuessSetupTsk>