hex.tree.dt.mrtasks

Class CountBinsSamplesCountsMRTask

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask<CountBinsSamplesCountsMRTask>

hex.tree.dt.mrtasks.CountBinsSamplesCountsMRTask

All Implemented Interfaces:

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

public class CountBinsSamplesCountsMRTask
extends water.MRTask<CountBinsSamplesCountsMRTask>

MR task for counting samples in bins.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.MRTask

water.MRTask.PostMapAction<T extends water.MRTask.PostMapAction<T>>

Nested classes/interfaces inherited from class water.DTask

water.DTask.DKeyTask<T extends water.DTask.DKeyTask,V extends water.Keyed>, water.DTask.RemoveCall

Field Summary

Fields

Modifier and Type	Field and Description
double[][]	_bins
int	_featureSplit
static int	COUNT
static int	COUNT_0
static int	NUMERICAL_FLAG

Fields inherited from class water.MRTask

_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nlo, _nrite, _rite, _run_local, _topLocal

Fields inherited from class water.DTask

_ex

Constructor Summary

Constructors

Constructor and Description
CountBinsSamplesCountsMRTask(int featureSplit, double[][] featuresLimits, double[][] bins)

Method Summary

Modifier and Type	Method and Description
void	map(water.fvec.Chunk[] cs)
void	reduce(CountBinsSamplesCountsMRTask mrt)

Methods inherited from class water.MRTask

appendables, asyncExecOnAllNodes, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, self, setupLocal, withPostMapAction

Methods inherited from class water.DTask

copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException

Methods inherited from class water.H2O.H2OCountedCompleter

asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON

Methods inherited from class jsr166y.CountedCompleter

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

_featureSplit

public final int _featureSplit

_bins

public double[][] _bins

NUMERICAL_FLAG

public static final int NUMERICAL_FLAG

See Also:

Constant Field Values

COUNT

public static final int COUNT

See Also:

Constant Field Values

COUNT_0

public static final int COUNT_0

See Also:

Constant Field Values

Constructor Detail

CountBinsSamplesCountsMRTask

public CountBinsSamplesCountsMRTask(int featureSplit,
                                    double[][] featuresLimits,
                                    double[][] bins)

Method Detail

map

public void map(water.fvec.Chunk[] cs)

Overrides:

map in class water.MRTask<CountBinsSamplesCountsMRTask>

reduce

public void reduce(CountBinsSamplesCountsMRTask mrt)

Overrides:

reduce in class water.MRTask<CountBinsSamplesCountsMRTask>