public static class PCAScore.PCAScoreTask extends FrameTask<PCAScore.PCAScoreTask>
FrameTask.DataInfo
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Iced>
_dinfo, _jobKey, _shuffle, _useFraction
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, skipMissing
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>