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>, Freezable

Direct Known Subclasses:

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

public abstract class DRemoteTask<T extends DRemoteTask>
extends DTask<T>
implements java.lang.Cloneable

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

protected Futures	_fs
protected boolean	_is_local
protected Key[]	_keys

Fields inherited from class water.DTask

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

Constructor Summary

DRemoteTask()

Method Summary

void	alsoBlockFor(java.util.concurrent.Future f)
void	alsoBlockFor(Futures fs)
T	clone()
void	compute2()
T	dfork(Key... keys)
Futures	getFutures()
void	init()
T	invoke(Key... keys)
T	invokeOnAllNodes()
void	keys(Key... keys)
abstract void	lcompute()
void	lonCompletion(jsr166y.CountedCompleter caller)
static double[][]	merge(double[][] a, double[][] b)
static int[]	merge(int[] a, int[] b)
static java.lang.String[]	merge(java.lang.String[] a, java.lang.String[] b)
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.
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

_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)

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)

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)

merge

public static double[][] merge(double[][] a,
                               double[][] b)

merge

public static int[] merge(int[] a,
                          int[] b)

merge

public static java.lang.String[] merge(java.lang.String[] a,
                                       java.lang.String[] b)

clone

public T clone()

Overrides:

clone in class DTask<T extends DRemoteTask>