alluxio.cli.fs.command

Class AbstractDistributedJobCommand

java.lang.Object

alluxio.cli.fs.command.AbstractFileSystemCommand

alluxio.cli.fs.command.AbstractDistributedJobCommand

All Implemented Interfaces:

Command, Closeable, AutoCloseable

Direct Known Subclasses:

AbstractTableCommand, DistributedCpCommand, DistributedLoadCommand, DistributedMvCommand

public abstract class AbstractDistributedJobCommand
extends AbstractFileSystemCommand

The base class for all the distributed job based Command classes. It provides handling for submitting multiple jobs and handling retries of them.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_ACTIVE_JOBS
protected int	mActiveJobs
protected JobMasterClient	mClient
protected List<JobAttempt>	mSubmittedJobAttempts

Fields inherited from class alluxio.cli.fs.command.AbstractFileSystemCommand

mFileSystem, mFsContext

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDistributedJobCommand(FileSystemContext fsContext)

Method Summary

Modifier and Type	Method and Description
protected void	drain()
int	getCompletedCount() Gets the number of completed jobs.
int	getFailedCount() Gets the number of failed jobs.
protected void	waitJob() Waits for at least one job to complete.

Methods inherited from class alluxio.cli.fs.command.AbstractFileSystemCommand

processHeader, runPlainPath, runWildCardCmd

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface alluxio.cli.Command

close, getCommandName, getDescription, getOptions, getSubCommands, getUsage, hasSubCommand, parseAndValidateArgs, run, validateArgs

Field Detail

DEFAULT_ACTIVE_JOBS

protected static final int DEFAULT_ACTIVE_JOBS

See Also:

Constant Field Values

mSubmittedJobAttempts

protected List<JobAttempt> mSubmittedJobAttempts

mActiveJobs

protected int mActiveJobs

mClient

protected final JobMasterClient mClient

Constructor Detail

AbstractDistributedJobCommand

protected AbstractDistributedJobCommand(FileSystemContext fsContext)

Method Detail

drain

protected void drain()

waitJob

protected void waitJob()

Waits for at least one job to complete.

getFailedCount

public int getFailedCount()

Gets the number of failed jobs.

Returns:

number of failed jobs

getCompletedCount

public int getCompletedCount()

Gets the number of completed jobs.

Returns:

the number of completed job