public static class CreateInteractions.createInteractionDomain extends MRTask<CreateInteractions.createInteractionDomain>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
CreateInteractions.createInteractionDomain(boolean same,
boolean interactOnNA) |
CreateInteractions.createInteractionDomain(boolean same,
boolean interactOnNA,
int[] restrictedEnumLeft,
int[] restrictedEnumRite) |
Modifier and Type | Method and Description |
---|---|
IcedHashMap<IcedLong,IcedLong> |
getMap() |
void |
map(Chunk A,
Chunk B)
Override with your map implementation.
|
void |
reduce(CreateInteractions.createInteractionDomain mrt)
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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, self, setupLocal
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, 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 CreateInteractions.createInteractionDomain(boolean same, boolean interactOnNA)
public CreateInteractions.createInteractionDomain(boolean same, boolean interactOnNA, int[] restrictedEnumLeft, int[] restrictedEnumRite)
public IcedHashMap<IcedLong,IcedLong> getMap()
public void map(Chunk A, Chunk B)
MRTask
map
in class MRTask<CreateInteractions.createInteractionDomain>
public void reduce(CreateInteractions.createInteractionDomain mrt)
MRTask
reduce
in class MRTask<CreateInteractions.createInteractionDomain>