public class DeepLearningTask extends FrameTask<DeepLearningTask>
_dinfo, _jobKey, _shuffle, _useFraction
Constructor and Description |
---|
DeepLearningTask(water.Key jobKey,
DeepLearningModel.DeepLearningModelInfo input,
float fraction) |
Modifier and Type | Method and Description |
---|---|
protected void |
chunkDone(long n)
Override this to do post-chunk processing work.
|
protected void |
chunkInit()
Override this to initialize at the beginning of chunk processing.
|
static Neurons[] |
makeNeuronsForTesting(DeepLearningModel.DeepLearningModelInfo minfo) |
static Neurons[] |
makeNeuronsForTraining(DeepLearningModel.DeepLearningModelInfo minfo) |
DeepLearningModel.DeepLearningModelInfo |
model_info() |
protected void |
postGlobal() |
void |
processRow(long seed,
DataInfo.Row r)
Method to process one row of the data for GLM functions.
|
void |
reduce(DeepLearningTask other) |
protected void |
setupLocal() |
static void |
step(long seed,
Neurons[] neurons,
DeepLearningModel.DeepLearningModelInfo minfo,
boolean training,
double[] responses) |
closeLocal, dfork, dinfo, map, processRow
appendables, asyncExec, asyncExec, asyncExec, block, compute2, dfork, dfork, dfork, dinvoke, 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, outputFrame, priority, profString, 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 DeepLearningTask(water.Key jobKey, DeepLearningModel.DeepLearningModelInfo input, float fraction)
public final DeepLearningModel.DeepLearningModelInfo model_info()
protected void setupLocal()
setupLocal
in class FrameTask<DeepLearningTask>
protected void chunkInit()
FrameTask
chunkInit
in class FrameTask<DeepLearningTask>
public final void processRow(long seed, DataInfo.Row r)
FrameTask
processRow
in class FrameTask<DeepLearningTask>
seed
- - global id of this row, in [0,_adaptedFrame.numRows())protected void chunkDone(long n)
FrameTask
chunkDone
in class FrameTask<DeepLearningTask>
n
- Number of processed rowspublic void reduce(DeepLearningTask other)
reduce
in class water.MRTask<DeepLearningTask>
protected void postGlobal()
postGlobal
in class water.MRTask<DeepLearningTask>
public static Neurons[] makeNeuronsForTraining(DeepLearningModel.DeepLearningModelInfo minfo)
public static Neurons[] makeNeuronsForTesting(DeepLearningModel.DeepLearningModelInfo minfo)
public static void step(long seed, Neurons[] neurons, DeepLearningModel.DeepLearningModelInfo minfo, boolean training, double[] responses)