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, setupLocalcopyOver, getDException, hasException, logVerbose, onAck, onAckAck, setExceptionasBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryCompleteadapt, 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, tryUnforkprotected 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)
MRTaskreduce in class MRTask<Model.BigScore>protected void postGlobal()
postGlobal in class MRTask<Model.BigScore>