protected class Model.BigScore extends CMetricScoringTask<Model.BigScore> implements Model.BigScorePredict, Model.BigScoreChunkPredict
MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
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 |
customMetricWs
Constructor and Description |
---|
BigScore(java.lang.String[] domain,
int ncols,
double[] mean,
boolean testHasWeights,
boolean computeMetrics,
boolean makePreds,
Job j,
CFuncRef customMetricFunc) |
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.
|
customMetricPerRow, getComputedCustomMetric, getFuncType
getFuncClassLoader, getParentClassloader
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, 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 final java.lang.String[] _domain
protected final int _npredcols
public final boolean _computeMetrics
public final boolean _hasWeights
public final boolean _makePreds
public final Job _j
public ModelMetrics.MetricBuilder _mb
protected void setupLocal()
MRTask
setupLocal
in class CFuncTask<CMetricFunc,Model.BigScore>
public void map(Chunk[] chks, NewChunk[] cpreds)
map
in class MRTask<Model.BigScore>
public double[] score0(Chunk[] chks, double offset, int row_in_chunk, double[] tmp, double[] preds)
score0
in interface Model.BigScoreChunkPredict
public Model.BigScoreChunkPredict initMap(Frame fr, Chunk[] chks)
initMap
in interface Model.BigScorePredict
public void close()
close
in interface Model.BigScoreChunkPredict
close
in interface java.lang.AutoCloseable
public void reduce(Model.BigScore bs)
MRTask
reduce
in class CMetricScoringTask<Model.BigScore>
protected void postGlobal()
postGlobal
in class CMetricScoringTask<Model.BigScore>