public static class PCAScore.PCAScoreTask extends FrameTask<PCAScore.PCAScoreTask>
FrameTask.DataInfo
_dinfo, _shuffle, _useFraction
_appendables, _fr, _fs, _hi, _left, _lo, _nhi, _nleft, _nrite, _nxx, _rite, _t0, _topLocal
_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth
Constructor and Description |
---|
PCAScore.PCAScoreTask(Job job,
FrameTask.DataInfo dinfo,
int nfeat,
int ncomp,
double[][] eigvec) |
Modifier and Type | Method and Description |
---|---|
protected void |
processRow(long gid,
double[] nums,
int ncats,
int[] cats,
double[] response,
NewChunk[] outputs) |
chunkDone, chunkInit, dfork, map, normMul, normRespMul, normRespSub, normSub, processRow
asyncExec, asyncExec, asyncExec, block, clone, closeLocal, compute2, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, exec, exec, exec, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, priority, profString, reduce, reduce4, setupLocal, vecs
copyOver, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFields
compute
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 PCAScore.PCAScoreTask(Job job, FrameTask.DataInfo dinfo, int nfeat, int ncomp, double[][] eigvec)
protected void processRow(long gid, double[] nums, int ncats, int[] cats, double[] response, NewChunk[] outputs)
processRow
in class FrameTask<PCAScore.PCAScoreTask>