public class ImportFilesHandler extends Handler
Currently import from local filesystem, hdfs and s3 is supported.
Constructor and Description |
---|
ImportFilesHandler() |
Modifier and Type | Method and Description |
---|---|
ImportFilesV3 |
importFiles(int version,
ImportFilesV3 importFiles) |
ImportFilesMultiV3 |
importFilesMulti(int version,
ImportFilesMultiV3 importFiles) |
getFromDKV, getFromDKV, getHandlerMethodInputSchema, getHandlerMethodOutputSchema, handle, markdown
asBytes, clone, compute, compute1, compute2, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, onExceptionalCompletion, 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 ImportFilesV3 importFiles(int version, ImportFilesV3 importFiles)
public ImportFilesMultiV3 importFilesMulti(int version, ImportFilesMultiV3 importFiles)