public class SharedTreeModelWithContributions.ScoreContributionsTask extends water.MRTask<SharedTreeModelWithContributions.ScoreContributionsTask>
Modifier and Type | Field and Description |
---|---|
protected SharedTreeModel |
_model |
protected water.Key<SharedTreeModel> |
_modelKey |
protected SharedTreeModel.SharedTreeOutput |
_output |
protected hex.genmodel.algos.tree.TreeSHAPPredictor<double[]> |
_treeSHAP |
Constructor and Description |
---|
ScoreContributionsTask(SharedTreeModel model) |
Modifier and Type | Method and Description |
---|---|
protected void |
addContribToNewChunk(float[] contribs,
water.fvec.NewChunk[] nc) |
protected void |
doModelSpecificComputation(float[] contribs) |
protected void |
fillInput(water.fvec.Chunk[] chks,
int row,
double[] input,
float[] contribs) |
void |
map(water.fvec.Chunk[] chks,
water.fvec.NewChunk[] nc) |
protected void |
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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, reduce, 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 water.Key<SharedTreeModel> _modelKey
protected transient SharedTreeModel _model
protected transient SharedTreeModel.SharedTreeOutput _output
protected transient hex.genmodel.algos.tree.TreeSHAPPredictor<double[]> _treeSHAP
public ScoreContributionsTask(SharedTreeModel model)
protected void setupLocal()
setupLocal
in class water.MRTask<SharedTreeModelWithContributions.ScoreContributionsTask>
protected void fillInput(water.fvec.Chunk[] chks, int row, double[] input, float[] contribs)
public void map(water.fvec.Chunk[] chks, water.fvec.NewChunk[] nc)
map
in class water.MRTask<SharedTreeModelWithContributions.ScoreContributionsTask>
protected void doModelSpecificComputation(float[] contribs)
protected void addContribToNewChunk(float[] contribs, water.fvec.NewChunk[] nc)