@ThreadSafe @PublicApi public final class DistributedLoadCommand extends AbstractDistributedJobCommand
ASYNC_OPTION, DEFAULT_ACTIVE_JOBS, mActiveJobs, mClient, mSubmittedJobAttempts
mFileSystem, mFsContext
Constructor and Description |
---|
DistributedLoadCommand(FileSystemContext fsContext)
Constructs a new instance to load a file or directory in Alluxio space.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Used to close resources created by commands.
|
String |
getCommandName()
Gets the command name as input from the shell.
|
String |
getDescription() |
org.apache.commons.cli.Options |
getOptions() |
String |
getUsage() |
int |
run(org.apache.commons.cli.CommandLine cl)
Runs the command.
|
void |
validateArgs(org.apache.commons.cli.CommandLine cl)
Checks if the arguments are valid or throw InvalidArgumentException.
|
drain, getCompletedCmdCount, getCompletedCount, getFailedCmdCount, getFailedCount, getFailedFiles, postProcessing, processFailures, submit, waitForCmd, waitJob
processHeader, runPlainPath, runWildCardCmd
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubCommands, hasSubCommand, parseAndValidateArgs
public DistributedLoadCommand(FileSystemContext fsContext)
fsContext
- the filesystem of Alluxiopublic String getCommandName()
Command
public org.apache.commons.cli.Options getOptions()
Options
of the commandpublic void validateArgs(org.apache.commons.cli.CommandLine cl) throws InvalidArgumentException
Command
cl
- the parsed command line for the argumentsInvalidArgumentException
- when arguments are not validpublic String getUsage()
public String getDescription()
public int run(org.apache.commons.cli.CommandLine cl) throws AlluxioException, IOException
Command
cl
- the parsed command line for the argumentsAlluxioException
IOException
public void close() throws IOException
Command
IOException
- if closing resources failsCopyright © 2023. All Rights Reserved.