water

Class DRemoteTask<T extends DRemoteTask>

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter

water.DTask<T>

water.DRemoteTask<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

DeepLearningTask2, DRF.DRFTask, FileIntegrityChecker, JStackCollectorTask, LogCollectorTask, MRTask, ParseDataset.UnzipAndParseTask, RemoveAllKeysTask

public abstract class DRemoteTask<T extends DRemoteTask>
extends DTask<T>
implements java.lang.Cloneable, jsr166y.ForkJoinPool.ManagedBlocker

A Distributed DTask. Execute a set of Keys on the home for each Key. Limited to doing a map/reduce style.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Futures	_fs
protected boolean	_is_local
protected Key[]	_keys
protected boolean	_top_level

Fields inherited from class water.DTask

_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth

Constructor Summary

Constructors

Constructor and Description
DRemoteTask()

Method Summary

Methods

Modifier and Type	Method and Description
void	alsoBlockFor(java.util.concurrent.Future f)
void	alsoBlockFor(Futures fs)
boolean	block() Possibly blocks the current thread, for example waiting for a lock or condition.
T	clone()
void	compute2()
T	dfork(Key... keys)
Futures	getFutures()
void	init()
T	invoke(Key... keys)
T	invokeOnAllNodes()
boolean	isReleasable() Returns true if blocking is unnecessary.
void	keys(Key... keys)
abstract void	lcompute()
void	lonCompletion(jsr166y.CountedCompleter caller)
void	onCompletion(jsr166y.CountedCompleter caller) Performs an action when method CountedCompleter.tryComplete() is invoked and there are no pending counts, or when the unconditional method CountedCompleter.complete(java.lang.Void) is invoked.
protected void	postGlobal()
abstract void	reduce(T drt)
protected void	reduceAlsoBlock(T drt)

Methods inherited from class water.DTask

copyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, onExceptionalCompletion, read, setException, toDocField, write, writeJSONFields

Methods inherited from class water.H2O.H2OCountedCompleter

compute, priority

Methods inherited from class jsr166y.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, 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

Field Detail

_keys

protected Key[] _keys

_is_local

protected transient boolean _is_local

_top_level

protected transient boolean _top_level

_fs

protected transient volatile Futures _fs

Constructor Detail

DRemoteTask

public DRemoteTask()

Method Detail

reduce

public abstract void reduce(T drt)

init

public void init()

invokeOnAllNodes

public T invokeOnAllNodes()

dfork

public T dfork(Key... keys)

keys

public void keys(Key... keys)

invoke

public T invoke(Key... keys)

isReleasable

public boolean isReleasable()

Description copied from interface: jsr166y.ForkJoinPool.ManagedBlocker

Returns true if blocking is unnecessary.

Specified by:

isReleasable in interface jsr166y.ForkJoinPool.ManagedBlocker

block

public boolean block()
              throws java.lang.InterruptedException

Description copied from interface: jsr166y.ForkJoinPool.ManagedBlocker

Possibly blocks the current thread, for example waiting for a lock or condition.

Specified by:

block in interface jsr166y.ForkJoinPool.ManagedBlocker

Returns:

true if no additional blocking is necessary (i.e., if isReleasable would return true)

Throws:

java.lang.InterruptedException - if interrupted while waiting (the method is not required to do so, but is allowed to)

compute2

public final void compute2()

Specified by:

compute2 in class H2O.H2OCountedCompleter

onCompletion

public final void onCompletion(jsr166y.CountedCompleter caller)

Description copied from class: jsr166y.CountedCompleter

Performs an action when method CountedCompleter.tryComplete() is invoked and there are no pending counts, or when the unconditional method CountedCompleter.complete(java.lang.Void) is invoked. By default, this method does nothing.

Overrides:

onCompletion in class jsr166y.CountedCompleter

Parameters:

caller - the task invoking this method (which may be this task itself).

lcompute

public abstract void lcompute()

lonCompletion

public void lonCompletion(jsr166y.CountedCompleter caller)

postGlobal

protected void postGlobal()

getFutures

public Futures getFutures()

alsoBlockFor

public void alsoBlockFor(java.util.concurrent.Future f)

alsoBlockFor

public void alsoBlockFor(Futures fs)

reduceAlsoBlock

protected void reduceAlsoBlock(T drt)

clone

public T clone()

Overrides:

clone in class H2O.H2OCountedCompleter