hex
Class ColSummaryTask

java.lang.Object
  jsr166y.ForkJoinTask<java.lang.Void>
      jsr166y.CountedCompleter
          water.H2O.H2OCountedCompleter
              water.DTask<T>
                  water.DRemoteTask<T>
                      water.MRTask<RowTask<T>>
                          hex.RowTask<Summary>
                              hex.ColSummaryTask

All Implemented Interfaces:

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

public final class ColSummaryTask
extends RowTask<Summary>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class hex.RowTask

RowTask.Row<T extends Freezable>, RowTask.RowFunction<T extends Iced>

Field Summary

Fields inherited from class water.MRTask

_hi, _lo

Fields inherited from class water.DRemoteTask

_fs, _is_local, _keys

Fields inherited from class water.DTask

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

Constructor Summary

ColSummaryTask(ValueArray ary, int[] cols)

Method Summary

void	map(RowTask.Row r, Summary summary)
Summary	newRes()
Summary	reduce(Summary left, Summary right)

Methods inherited from class hex.RowTask

map, reduce, result

Methods inherited from class water.MRTask

hi, init, lcompute, lo, lonCompletion, memOverheadPerChunk, onExceptionalCompletion

Methods inherited from class water.DRemoteTask

alsoBlockFor, alsoBlockFor, clone, compute2, dfork, getFutures, invoke, invokeOnAllNodes, keys, merge, merge, merge, onCompletion, reduceAlsoBlock

Methods inherited from class water.DTask

copyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, 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

Constructor Detail

ColSummaryTask

public ColSummaryTask(ValueArray ary,
                      int[] cols)

Method Detail

newRes

public Summary newRes()

Specified by:

newRes in class RowTask<Summary>

map

public void map(RowTask.Row r,
                Summary summary)

Specified by:

map in class RowTask<Summary>

reduce

public Summary reduce(Summary left,
                      Summary right)

Specified by:

reduce in class RowTask<Summary>