public class ScoreBuildHistogram extends water.MRTask<ScoreBuildHistogram>
Fuse 2 conceptual passes into one:
The result is a set of DHistogram arrays; one DHistogram array for each unique 'leaf' in the tree being histogramed in parallel. These have node ID's (nids) from 'leaf' to 'tree._len'. Each DHistogram array is for all the columns in that 'leaf'.
The other result is a prediction "score" for the whole dataset, based on the previous passes' DHistograms.
Modifier and Type | Field and Description |
---|---|
static int |
DECIDED_ROW
Marker for already decided row.
|
static int |
OUT_OF_BAG
Marker for sampled out rows
|
Constructor and Description |
---|
ScoreBuildHistogram(water.H2O.H2OCountedCompleter cc,
int k,
int ncols,
int nbins,
int nbins_cats,
DTree tree,
int leaf,
DHistogram[][] hcs,
boolean subset) |
Modifier and Type | Method and Description |
---|---|
static boolean |
isDecidedRow(int nid) |
static boolean |
isOOBRow(int nid) |
void |
map(water.fvec.Chunk[] chks) |
static int |
nid2Oob(int nid) |
static int |
oob2Nid(int oobNid) |
void |
reduce(ScoreBuildHistogram sbh) |
void |
setupLocal() |
appendables, asyncExec, asyncExec, asyncExec, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, postLocal, priority, profString, self, setProfile
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
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
public static final int DECIDED_ROW
public static final int OUT_OF_BAG
public ScoreBuildHistogram(water.H2O.H2OCountedCompleter cc, int k, int ncols, int nbins, int nbins_cats, DTree tree, int leaf, DHistogram[][] hcs, boolean subset)
public static boolean isOOBRow(int nid)
public static boolean isDecidedRow(int nid)
public static int oob2Nid(int oobNid)
public static int nid2Oob(int nid)
public void setupLocal()
setupLocal
in class water.MRTask<ScoreBuildHistogram>
public void map(water.fvec.Chunk[] chks)
map
in class water.MRTask<ScoreBuildHistogram>
public void reduce(ScoreBuildHistogram sbh)
reduce
in class water.MRTask<ScoreBuildHistogram>