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 byte[] |
_ex
A distributable exception object, thrown by
dinvoke(water.H2ONode) . |
Modifier | Constructor and Description |
---|---|
protected |
DTask() |
protected |
DTask(byte prior) |
protected |
DTask(H2O.H2OCountedCompleter completer) |
protected |
DTask(H2O.H2OCountedCompleter completer,
byte prior) |
Modifier and Type | Method and Description |
---|---|
protected void |
copyOver(T src) |
void |
dinvoke(H2ONode sender)
Top-level remote execution hook.
|
java.lang.Throwable |
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.
|
asBytes, clone, compute, compute1, compute2, 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 byte[] _ex
dinvoke(water.H2ONode)
.protected DTask(H2O.H2OCountedCompleter completer, byte prior)
protected DTask(H2O.H2OCountedCompleter completer)
protected DTask(byte prior)
protected DTask()
public final boolean hasException()
dinvoke(water.H2ONode)
threw an exception.public void setException(java.lang.Throwable ex)
public java.lang.Throwable getDException()
public void dinvoke(H2ONode sender)
public void onAck()
public void onAckAck()
public boolean logVerbose()
protected void copyOver(T src)