public class NFoldFrameExtractor extends FrameExtractor
| Constructor and Description |
|---|
NFoldFrameExtractor(Frame dataset,
int nfolds,
int afold,
Key[] destKeys,
Key jobKey) |
| Modifier and Type | Method and Description |
|---|---|
protected long[][] |
computeEspcPerSplit(long[] espc,
long nrows)
Compute espc for output vectors for each split.
|
protected MRTask2 |
createNewWorker(H2O.H2OCountedCompleter completer,
Vec[] inputVecs,
int split)
Create a new worker which has to setup given completer.
|
protected int |
numOfOutputs()
Return a number of resulting frame which this task produces.
|
compute2, generateDestKeys, getResult, makeTemplates, onCompletionclone, compute, onExceptionalCompletion, 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, tryUnforkprotected MRTask2 createNewWorker(H2O.H2OCountedCompleter completer, Vec[] inputVecs, int split)
FrameExtractorcreateNewWorker in class FrameExtractorprotected long[][] computeEspcPerSplit(long[] espc,
long nrows)
FrameExtractorcomputeEspcPerSplit in class FrameExtractorespc - input vector espcnrows - total number of rows in input vectorprotected int numOfOutputs()
FrameExtractornumOfOutputs in class FrameExtractor