hex

Class Model.BigScore

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask<S>

water.udf.CFuncTask<CMetricFunc,T>

hex.CMetricScoringTask<Model.BigScore>

hex.Model.BigScore

All Implemented Interfaces:

Model.BigScoreChunkPredict, Model.BigScorePredict, java.io.Serializable, java.lang.AutoCloseable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, ForkJoinPool.ManagedBlocker, Freezable<Model.BigScore>

Enclosing class:

Model<M extends Model<M,P,O>,P extends Model.Parameters,O extends Model.Output>

protected class Model.BigScore
extends CMetricScoringTask<Model.BigScore>
implements Model.BigScorePredict, Model.BigScoreChunkPredict

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.DTask

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

Field Summary

Fields

Modifier and Type	Field and Description
boolean	_computeMetrics
protected java.lang.String[]	_domain
boolean	_hasWeights
Job	_j
boolean	_makePreds
ModelMetrics.MetricBuilder	_mb Output parameter: Metric builder
protected int	_npredcols

Fields inherited from class hex.CMetricScoringTask

customMetricWs

Fields inherited from class water.udf.CFuncTask

cFuncRef, func

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
BigScore(java.lang.String[] domain, int ncols, double[] mean, boolean testHasWeights, boolean computeMetrics, boolean makePreds, Job j, CFuncRef customMetricFunc)

Method Summary

Modifier and Type	Method and Description
void	close()
Model.BigScoreChunkPredict	initMap(Frame fr, Chunk[] chks)
void	map(Chunk[] chks, NewChunk[] cpreds)
protected void	postGlobal()
void	reduce(Model.BigScore bs) Override to combine results from 'mrt' into 'this' MRTask.
double[]	score0(Chunk[] chks, double offset, int row_in_chunk, double[] tmp, double[] preds)
protected void	setupLocal() Override to do any remote initialization on the 1st remote instance of this object, for initializing node-local shared data structures.

Methods inherited from class hex.CMetricScoringTask

customMetricPerRow, getComputedCustomMetric, getFuncType

Methods inherited from class water.udf.CFuncTask

getFuncClassLoader, getParentClassloader

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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, profile, profString, self

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

_domain

protected final java.lang.String[] _domain

_npredcols

protected final int _npredcols

_computeMetrics

public final boolean _computeMetrics

_hasWeights

public final boolean _hasWeights

_makePreds

public final boolean _makePreds

_j

public final Job _j

_mb

public ModelMetrics.MetricBuilder _mb

Output parameter: Metric builder

Constructor Detail

BigScore

public BigScore(java.lang.String[] domain,
                int ncols,
                double[] mean,
                boolean testHasWeights,
                boolean computeMetrics,
                boolean makePreds,
                Job j,
                CFuncRef customMetricFunc)

Method Detail

setupLocal

protected void setupLocal()

Description copied from class: MRTask

Override to do any remote initialization on the 1st remote instance of this object, for initializing node-local shared data structures.

Overrides:

setupLocal in class CFuncTask<CMetricFunc,Model.BigScore>

map

public void map(Chunk[] chks,
                NewChunk[] cpreds)

Overrides:

map in class MRTask<Model.BigScore>

score0

public double[] score0(Chunk[] chks,
                       double offset,
                       int row_in_chunk,
                       double[] tmp,
                       double[] preds)

Specified by:

score0 in interface Model.BigScoreChunkPredict

initMap

public Model.BigScoreChunkPredict initMap(Frame fr,
                                          Chunk[] chks)

Specified by:

initMap in interface Model.BigScorePredict

close

public void close()

Specified by:

close in interface Model.BigScoreChunkPredict

Specified by:

close in interface java.lang.AutoCloseable

reduce

public void reduce(Model.BigScore bs)

Description copied from class: MRTask

Override to combine results from 'mrt' into 'this' MRTask. Both 'this' and 'mrt' are guaranteed to either have map() run on them, or be the results of a prior reduce(). Reduce is optional if, e.g., the result is some output vector.

Overrides:

reduce in class CMetricScoringTask<Model.BigScore>

postGlobal

protected void postGlobal()

Overrides:

postGlobal in class CMetricScoringTask<Model.BigScore>