alluxio.master.job.tracker

Class AbstractCmdRunner

java.lang.Object

alluxio.master.job.tracker.AbstractCmdRunner

Direct Known Subclasses:

DistLoadCliRunner, MigrateCliRunner

public abstract class AbstractCmdRunner
extends Object

The base class for all the distributed job runner 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 static long	DEFAULT_FILE_COUNT
protected int	mActiveJobs
protected FileSystem	mFileSystem
protected FileSystemContext	mFsContext
protected Map<Long,List<CmdRunAttempt>>	mJobMap
protected JobMaster	mJobMaster
protected List<CmdRunAttempt>	mSubmitted

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractCmdRunner(FileSystemContext fsContext, JobMaster jobMaster)

Method Summary

Modifier and Type	Method and Description
protected void	waitForCmdJob() Waits for at least one job to complete.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ACTIVE_JOBS

protected static final int DEFAULT_ACTIVE_JOBS

See Also:

Constant Field Values

DEFAULT_FILE_COUNT

protected static final long DEFAULT_FILE_COUNT

See Also:

Constant Field Values

mFileSystem

protected FileSystem mFileSystem

mFsContext

protected FileSystemContext mFsContext

mSubmitted

protected List<CmdRunAttempt> mSubmitted

mJobMap

protected Map<Long,List<CmdRunAttempt>> mJobMap

mActiveJobs

protected int mActiveJobs

mJobMaster

protected final JobMaster mJobMaster

Constructor Detail

AbstractCmdRunner

protected AbstractCmdRunner(@Nullable
                            FileSystemContext fsContext,
                            JobMaster jobMaster)

Method Detail

waitForCmdJob

protected void waitForCmdJob()

Waits for at least one job to complete.