public final class BaseStatsTask extends MRTask
_hi, _lo, _runSingleThreaded_fs, _is_local, _keys, _top_level_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth| Constructor and Description |
|---|
BaseStatsTask(ValueArray ary) |
| Modifier and Type | Method and Description |
|---|---|
ValueArray.Column[] |
getCols() |
void |
map(Key key)
Run some useful function over this local key, and
record the results in the this MRTask.
|
double |
max(int c) |
double |
mean(int c) |
double |
min(int c) |
long |
nobs(int c) |
void |
reduce(DRemoteTask drt) |
double |
sigma(int c) |
hi, init, lcompute, lo, lonCompletion, memOverheadPerChunk, onExceptionalCompletionalsoBlockFor, alsoBlockFor, block, clone, compute2, dfork, getFutures, invoke, invokeOnAllNodes, isReleasable, keys, onCompletion, postGlobal, reduceAlsoBlockcopyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFieldscompute, priorityaddToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryCompleteadapt, 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, tryUnforkpublic BaseStatsTask(ValueArray ary)
public void map(Key key)
MRTaskpublic void reduce(DRemoteTask drt)
reduce in class DRemoteTaskpublic double min(int c)
public double max(int c)
public double mean(int c)
public double sigma(int c)
public long nobs(int c)
public ValueArray.Column[] getCols()