public abstract class DTask<T extends DTask> extends H2O.H2OCountedCompleter<T>
dinvoke(water.H2ONode)
is remotely executed.
Efficient serialization methods for subclasses will be automatically generated, but explicit ones can be provided. Transient fields will not be mirrored between the VMs.
dinvoke(H2ONode)
method will be executed.onAck()
method will be executed.onAckAck()
method will be executed.Modifier and Type | Class and Description |
---|---|
static class |
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>
Task to be executed at the home node of the given key.
|
static class |
DTask.RemoveCall
Task to cleanly remove value from the K/V (call it's remove()
destructor) without the need to fetch it locally first.
|
Modifier and Type | Field and Description |
---|---|
protected DException |
_ex
A distributable exception object, thrown by
dinvoke(water.H2ONode) . |
protected boolean |
_modifiesInputs |
Modifier | Constructor and Description |
---|---|
protected |
DTask() |
|
DTask(H2O.H2OCountedCompleter completer) |
Modifier and Type | Method and Description |
---|---|
protected void |
copyOver(T src) |
void |
dinvoke(H2ONode sender)
Top-level remote execution hook.
|
DException.DistributedException |
getDException()
The _ex field as a RuntimeException or null.
|
boolean |
hasException()
True if
dinvoke(water.H2ONode) threw an exception. |
boolean |
logVerbose()
Override to remove 2 lines of logging per RPC.
|
void |
onAck()
2nd top-level execution hook.
|
void |
onAckAck()
3rd top-level execution hook.
|
void |
setException(java.lang.Throwable ex)
Capture the first exception in _ex.
|
clone, compute, compute2, frozenType, icer, nextThrPriority, onExceptionalCompletion, priority, 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
protected boolean _modifiesInputs
protected DException _ex
dinvoke(water.H2ONode)
.protected DTask()
public DTask(H2O.H2OCountedCompleter completer)
public final boolean hasException()
dinvoke(water.H2ONode)
threw an exception.public void setException(java.lang.Throwable ex)
public DException.DistributedException getDException()
public void dinvoke(H2ONode sender)
public void onAck()
public void onAckAck()
public boolean logVerbose()
protected void copyOver(T src)