public static class FrameUtils.CalculateWeightMeanSTD extends MRTask<FrameUtils.CalculateWeightMeanSTD>
MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
long |
_nonZeroWeightsNum |
double |
_weightedCount |
double |
_weightedEleSqSum |
double |
_weightedEleSum |
double |
_weightedMean |
double |
_weightedSigma |
Constructor and Description |
---|
CalculateWeightMeanSTD() |
Modifier and Type | Method and Description |
---|---|
double |
getWeightedMean() |
double |
getWeightedSigma() |
void |
map(Chunk pcs,
Chunk wcs)
Override with your map implementation.
|
void |
postGlobal() |
void |
reduce(FrameUtils.CalculateWeightMeanSTD other)
Override to combine results from 'mrt' into 'this' MRTask.
|
appendables, asyncExecOnAllNodes, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, profile, profString, self, setupLocal, withPostMapAction
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, 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 double _weightedEleSum
public double _weightedEleSqSum
public double _weightedCount
public double _weightedMean
public double _weightedSigma
public long _nonZeroWeightsNum
public void map(Chunk pcs, Chunk wcs)
MRTask
map
in class MRTask<FrameUtils.CalculateWeightMeanSTD>
public void reduce(FrameUtils.CalculateWeightMeanSTD other)
MRTask
reduce
in class MRTask<FrameUtils.CalculateWeightMeanSTD>
public void postGlobal()
postGlobal
in class MRTask<FrameUtils.CalculateWeightMeanSTD>
public double getWeightedMean()
public double getWeightedSigma()