hex

Class CMetricScoringTask<T extends CMetricScoringTask<T>>

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

Type Parameters:

T - self type

All Implemented Interfaces:

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

Direct Known Subclasses:

Model.BigScore

public class CMetricScoringTask<T extends CMetricScoringTask<T>>
extends CFuncTask<CMetricFunc,T>

Custom metric scoring task. The task provides support to load and invoke custom model metric defined via CFuncTask.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.MRTask

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

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
protected double[]	customMetricWs Internal parameter to preserve workspace for custom metric computation

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
CMetricScoringTask(CFuncRef cFuncRef)

Method Summary

Modifier and Type	Method and Description
CustomMetric	computeCustomMetric()
protected void	customMetricPerRow(double[] preds, float[] yact, double weight, double offset, Model m)
CustomMetric	getComputedCustomMetric()
protected java.lang.Class<CMetricFunc>	getFuncType()
protected void	postGlobal()
void	reduce(T t) Override to combine results from 'mrt' into 'this' MRTask.
void	reduceCustomMetric(T t)

Methods inherited from class water.udf.CFuncTask

getFuncClassLoader, getParentClassloader, setupLocal

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

customMetricWs

protected double[] customMetricWs

Internal parameter to preserve workspace for custom metric computation

Constructor Detail

CMetricScoringTask

public CMetricScoringTask(CFuncRef cFuncRef)

Method Detail

getFuncType

protected final java.lang.Class<CMetricFunc> getFuncType()

Specified by:

getFuncType in class CFuncTask<CMetricFunc,T extends CMetricScoringTask<T>>

customMetricPerRow

protected final void customMetricPerRow(double[] preds,
                                        float[] yact,
                                        double weight,
                                        double offset,
                                        Model m)

reduce

public void reduce(T t)

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 MRTask<T extends CMetricScoringTask<T>>

reduceCustomMetric

public void reduceCustomMetric(T t)

postGlobal

protected void postGlobal()

Overrides:

postGlobal in class MRTask<T extends CMetricScoringTask<T>>

computeCustomMetric

public CustomMetric computeCustomMetric()

getComputedCustomMetric

public CustomMetric getComputedCustomMetric()