public static class GLMTask.DataAddW2AugXZ extends water.MRTask<GLMTask.DataAddW2AugXZ>
Modifier and Type | Field and Description |
---|---|
int |
_dataColNumber |
long |
_dataRows |
DataInfo |
_dinfo |
int |
_numColStart |
int |
_numRandCol |
int[] |
_randCatLevels |
int |
_wdataID |
Constructor and Description |
---|
DataAddW2AugXZ(water.Job job,
DataInfo dInfo,
int[] randCatLevels) |
Modifier and Type | Method and Description |
---|---|
static void |
getAllChunks(water.fvec.Frame augXZ,
int chkIdx,
water.fvec.Chunk[] chks,
int[] vecIdx)
Given the chkIdx, this method will fetch the chunks with columns specified in vecIdx
|
static int[] |
getCorrectChunk(water.fvec.Frame augXZ,
int chkIdx,
long currentRowAbs,
water.fvec.Chunk[] chks,
int[] vecIdx,
int[] returnInfo)
This method, given the absolute row index of interest, will grab the correct chunk from augXZ containing the
same absolute row index of interest.
|
static int |
getOneSingleChunk(water.fvec.Frame augXZ,
int chkIdx,
long currentRowAbs,
water.fvec.Chunk[] chks,
int[] vecIdx)
Given the absolute row index of interest, this method will find the chunk index of augXZ that contains the
absolute row index
|
void |
map(water.fvec.Chunk[] chunks) |
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, setupLocal, 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
public DataInfo _dinfo
public int _wdataID
public int[] _randCatLevels
public int _dataColNumber
public int _numColStart
public int _numRandCol
public long _dataRows
public DataAddW2AugXZ(water.Job job, DataInfo dInfo, int[] randCatLevels)
public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.DataAddW2AugXZ>
public static void getAllChunks(water.fvec.Frame augXZ, int chkIdx, water.fvec.Chunk[] chks, int[] vecIdx)
augXZ:
- Frame frome which chunks are fetchedchkIdx:
- chunk index to fetchchks:
- store fetched chunksvecIdx:
- null, fetch all columns, else, contains columns of interest to fetchpublic static int getOneSingleChunk(water.fvec.Frame augXZ, int chkIdx, long currentRowAbs, water.fvec.Chunk[] chks, int[] vecIdx)
augXZ:
- Frame where chunks will be fetchedchkIdx:
- chunk index to check if it contains the absolute row index of interestcurrentRowAbs:
- absolute row index of interestchks:
- chunks to stored fetched chunkvecIdx:
- column indices to fetch. If null, fetch all columnspublic static int[] getCorrectChunk(water.fvec.Frame augXZ, int chkIdx, long currentRowAbs, water.fvec.Chunk[] chks, int[] vecIdx, int[] returnInfo)
augXZ:
- Frame from which chunks will be grabbedchkIdx:
- starting chunk index to looking atcurrentRowAbs:
- absolute row index of first row of interestchks:
- stored fetched chunkvecIdx:
- null if all columns should be fetched. Else, contains the columns to be fetchedreturnInfo:
- information about fetched chunk