T
- self typepublic class CMetricScoringTask<T extends CMetricScoringTask<T>> extends CFuncTask<CMetricFunc,T>
CFuncTask
.MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
protected double[] |
customMetricWs
Internal parameter to preserve workspace for custom metric computation
|
Constructor and Description |
---|
CMetricScoringTask(CFuncRef cFuncRef) |
Modifier and Type | Method and Description |
---|---|
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.
|
getFuncClassLoader, getParentClassloader, setupLocal
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
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete
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
protected double[] customMetricWs
public CMetricScoringTask(CFuncRef cFuncRef)
protected final java.lang.Class<CMetricFunc> getFuncType()
getFuncType
in class CFuncTask<CMetricFunc,T extends CMetricScoringTask<T>>
protected final void customMetricPerRow(double[] preds, float[] yact, double weight, double offset, Model m)
public void reduce(T t)
MRTask
reduce
in class MRTask<T extends CMetricScoringTask<T>>
protected void postGlobal()
postGlobal
in class MRTask<T extends CMetricScoringTask<T>>
public CustomMetric getComputedCustomMetric()