protected class Model.BigScore extends MRTask<Model.BigScore>
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 |
protected int |
_npredcols |
Constructor and Description |
---|
Model.BigScore(java.lang.String[] domain,
int ncols,
double[] mean,
boolean testHasWeights,
boolean computeMetrics,
boolean makePreds,
Job j) |
Modifier and Type | Method and Description |
---|---|
void |
map(Chunk[] chks,
NewChunk[] cpreds) |
protected void |
postGlobal() |
void |
reduce(Model.BigScore bs)
Override to combine results from 'mrt' into 'this' 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, setupLocal
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, 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 ModelMetrics.MetricBuilder _mb
public final boolean _computeMetrics
public final boolean _hasWeights
public final boolean _makePreds
public final Job _j
public Model.BigScore(java.lang.String[] domain, int ncols, double[] mean, boolean testHasWeights, boolean computeMetrics, boolean makePreds, Job j)
public void map(Chunk[] chks, NewChunk[] cpreds)
map
in class MRTask<Model.BigScore>
public void reduce(Model.BigScore bs)
MRTask
reduce
in class MRTask<Model.BigScore>
protected void postGlobal()
postGlobal
in class MRTask<Model.BigScore>