public class TaskPutKey extends DTask<TaskPutKey>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier | Constructor and Description |
---|---|
protected |
TaskPutKey(Key key) |
protected |
TaskPutKey(Key key,
Value val) |
protected |
TaskPutKey(Key key,
Value val,
boolean removeCache) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
void |
dinvoke(H2ONode sender)
Top-level remote execution hook.
|
void |
onAck()
2nd top-level execution hook.
|
copyOver, getDException, hasException, logVerbose, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, onExceptionalCompletion, 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
protected TaskPutKey(Key key)
public void dinvoke(H2ONode sender)
DTask
dinvoke
in class DTask<TaskPutKey>
public void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<TaskPutKey>
public void onAck()
DTask
onAck
in class DTask<TaskPutKey>