public class TaskPutKey extends DTask<TaskPutKey>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
_ex, _modifiesInputs
Modifier | Constructor and Description |
---|---|
protected |
TaskPutKey(Key key,
Value val) |
protected |
TaskPutKey(Key key,
Value val,
boolean removeCache) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override to specify actual work to do
|
void |
dinvoke(H2ONode sender)
Top-level remote execution hook.
|
void |
onAck()
2nd top-level execution hook.
|
byte |
priority() |
copyOver, getDException, hasException, logVerbose, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, onExceptionalCompletion, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, 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 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>
public byte priority()
priority
in class H2O.H2OCountedCompleter<TaskPutKey>