water

Class DTask<T extends DTask>

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter

water.DTask<T>

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, Freezable

Direct Known Subclasses:

Atomic, FetchClazz, FetchId, MRTask, RollupStats, TaskGetKey, TaskPutKey

public abstract class DTask<T extends DTask>
extends H2O.H2OCountedCompleter
implements Freezable

Objects which are passed and 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.

1. On the local vm, this task will be serialized and sent to a remote.
2. On the remote, the task will be deserialized.
3. On the remote, the dinvoke(H2ONode) method will be executed.
4. On the remote, the task will be serialized and sent to the local vm
5. On the local vm, the task will be deserialized into the original instance
6. On the local vm, the onAck() method will be executed.
7. On the remote, the onAckAck() method will be executed.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected DException	_ex

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DTask()
	DTask(H2O.H2OCountedCompleter completer)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	copyOver(T src)
void	dinvoke(H2ONode sender) Top-level remote execution hook.
DException.DistributedException	getDException()
boolean	hasException()
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)

Methods inherited from class water.H2O.H2OCountedCompleter

clone, compute, compute2, frozenType, icer, nextThrPriority, onExceptionalCompletion, priority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Methods inherited from class jsr166y.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface water.Freezable

clone, frozenType, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Field Detail

_ex

protected DException _ex

Constructor Detail

DTask

protected DTask()

DTask

public DTask(H2O.H2OCountedCompleter completer)

Method Detail

hasException

public final boolean hasException()

setException

public void setException(java.lang.Throwable ex)

getDException

public DException.DistributedException getDException()

dinvoke

public void dinvoke(H2ONode sender)

Top-level remote execution hook. Called on the remote.

onAck

public void onAck()

2nd top-level execution hook. After the primary task has received a result (ACK) and before we have sent an ACKACK, this method is executed on the local vm. Transients from the local vm are available here.

onAckAck

public void onAckAck()

3rd top-level execution hook. After the original vm sent an ACKACK, this method is executed on the remote. Transients from the remote vm are available here.

logVerbose

public boolean logVerbose()

Override to remove 2 lines of logging per RPC. 0.5M RPC's will lead to 1M lines of logging at about 50 bytes/line produces 50M of log file, which will swamp all other logging output.

copyOver

protected void copyOver(T src)