public static class FrameUtils.Vecs2ArryTsk extends MRTask<FrameUtils.Vecs2ArryTsk>
MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
double[][] |
res |
Constructor and Description |
---|
Vecs2ArryTsk(int dim1,
int dim2) |
Modifier and Type | Method and Description |
---|---|
void |
map(Chunk[] c)
Override with your map implementation.
|
void |
reduce(FrameUtils.Vecs2ArryTsk other)
Override to combine results from 'mrt' into 'this' MRTask.
|
void |
setupLocal()
Override to do any remote initialization on the 1st remote instance of
this object, for initializing node-local shared data structures.
|
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, postGlobal, profile, profString, self, 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 void setupLocal()
MRTask
setupLocal
in class MRTask<FrameUtils.Vecs2ArryTsk>
public void map(Chunk[] c)
MRTask
map
in class MRTask<FrameUtils.Vecs2ArryTsk>
public void reduce(FrameUtils.Vecs2ArryTsk other)
MRTask
reduce
in class MRTask<FrameUtils.Vecs2ArryTsk>