public class DeepLearningTask2 extends DRemoteTask<DeepLearningTask2>
_fs, _is_local, _keys, _top_level_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth| Constructor and Description |
|---|
DeepLearningTask2(Frame train,
DeepLearningModel.DeepLearningModelInfo model_info,
float sync_fraction)
Construct a DeepLearningTask2 where every node trains on the entire training dataset
|
| Modifier and Type | Method and Description |
|---|---|
void |
lcompute()
Do the local computation: Perform one DeepLearningTask (with run_local=true) iteration.
|
DeepLearningModel.DeepLearningModelInfo |
model_info()
Returns the aggregated DeepLearning model that was trained by all nodes (over all the training data)
|
protected void |
postGlobal()
Finish up the work after all nodes have reduced their models via the above reduce() method.
|
void |
reduce(DeepLearningTask2 drt)
Reduce between worker ndoes, with network traffic (if greater than 1 nodes)
After all reduce()'s are done, postGlobal() will be called
|
alsoBlockFor, alsoBlockFor, block, clone, compute2, dfork, getFutures, init, invoke, invokeOnAllNodes, isReleasable, keys, lonCompletion, onCompletion, reduceAlsoBlockcopyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, onExceptionalCompletion, read, setException, toDocField, write, writeJSONFieldscompute, priorityaddToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryCompleteadapt, 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, tryUnforkpublic DeepLearningTask2(Frame train, DeepLearningModel.DeepLearningModelInfo model_info, float sync_fraction)
train - Frame containing training datamodel_info - Initial DeepLearningModelInfo (weights + biases)sync_fraction - Fraction of the training data to use for one SGD iterationpublic DeepLearningModel.DeepLearningModelInfo model_info()
public void lcompute()
lcompute in class DRemoteTask<DeepLearningTask2>public void reduce(DeepLearningTask2 drt)
reduce in class DRemoteTask<DeepLearningTask2>drt - protected void postGlobal()
postGlobal in class DRemoteTask<DeepLearningTask2>