protected static class CoxPH.CoxPHTask extends FrameTask<CoxPH.CoxPHTask>
FrameTask.ExtractDenseRow
Modifier and Type | Field and Description |
---|---|
protected long[] |
countEvents |
protected long |
n |
protected double[] |
rcumsumRisk |
protected double[][] |
rcumsumXRisk |
protected double[][][] |
rcumsumXXRisk |
protected double[] |
sizeCensored |
protected double[] |
sizeEvents |
protected double[] |
sizeRiskSet |
protected double[] |
sumLogRiskEvents |
protected double[] |
sumRiskEvents |
protected double[] |
sumWeightedCatX |
protected double[] |
sumWeightedNumX |
protected double |
sumWeights |
protected double[][] |
sumXEvents |
protected double[][] |
sumXRiskEvents |
protected double[][][] |
sumXXRiskEvents |
Modifier and Type | Method and Description |
---|---|
protected boolean |
chunkInit()
Override this to initialize at the beginning of chunk processing.
|
protected void |
postGlobal() |
protected void |
processRow(long gid,
DataInfo.Row row)
Method to process one row of the data.
|
void |
reduce(CoxPH.CoxPHTask that) |
chunkDone, closeLocal, dinfo, getMiniBatchSize, map, processMiniBatch, processRow, processRow, setupLocal
appendables, asyncExecOnAllNodes, block, 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
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 long n
protected double sumWeights
protected double[] sumWeightedCatX
protected double[] sumWeightedNumX
protected double[] sizeRiskSet
protected double[] sizeCensored
protected double[] sizeEvents
protected long[] countEvents
protected double[][] sumXEvents
protected double[] sumRiskEvents
protected double[][] sumXRiskEvents
protected double[][][] sumXXRiskEvents
protected double[] sumLogRiskEvents
protected double[] rcumsumRisk
protected double[][] rcumsumXRisk
protected double[][][] rcumsumXXRisk
protected boolean chunkInit()
FrameTask
chunkInit
in class FrameTask<CoxPH.CoxPHTask>
protected void processRow(long gid, DataInfo.Row row)
FrameTask
processRow
in class FrameTask<CoxPH.CoxPHTask>
gid
- - global id of this row, in [0,_adaptedFrame.numRows())public void reduce(CoxPH.CoxPHTask that)
reduce
in class water.MRTask<CoxPH.CoxPHTask>
protected void postGlobal()
postGlobal
in class water.MRTask<CoxPH.CoxPHTask>