alluxio.master.job.tracker

Class CmdJobTracker

java.lang.Object

alluxio.master.job.tracker.CmdJobTracker

@ThreadSafe
public class CmdJobTracker
extends Object

CmdJobTracker to schedule a Cmd job to run.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELIMITER
protected FileSystemContext	mFsContext

Constructor Summary

Constructors

Constructor and Description
CmdJobTracker(FileSystemContext fsContext, JobMaster jobMaster) Create a new instance of CmdJobTracker.
CmdJobTracker(FileSystemContext fsContext, MigrateCliRunner migrateCliRunner, PersistRunner persistRunner) Constructor with runner providers.

Method Summary

Modifier and Type	Method and Description
Set<String>	findAllFailedPaths()
Set<Long>	findCmdIds(List<Status> statusList)
Set<String>	findFailedPaths(long jobControlId)
Status	getCmdStatus(long jobControlId) Get status information for a CMD.
CmdStatusBlock	getCmdStatusBlock(long jobControlId) Get a cmdStatusBlock information.
void	run(CmdConfig cmdConfig, long jobControlId) Run the PlanTracker to trigger a Cmd job based on CmdConfig.

Methods inherited from class java.lang.Object

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

Field Detail

mFsContext

protected FileSystemContext mFsContext

DELIMITER

public static final String DELIMITER

See Also:

Constant Field Values

Constructor Detail

CmdJobTracker

public CmdJobTracker(FileSystemContext fsContext,
                     JobMaster jobMaster)

Create a new instance of CmdJobTracker.

Parameters:

fsContext - filesystem context

jobMaster - the job master

CmdJobTracker

public CmdJobTracker(FileSystemContext fsContext,
                     MigrateCliRunner migrateCliRunner,
                     PersistRunner persistRunner)

Constructor with runner providers.

Parameters:

fsContext - Filesystem context

migrateCliRunner - DistributedCopy runner

persistRunner - Persist runner

Method Detail

run

public void run(CmdConfig cmdConfig,
                long jobControlId)
         throws JobDoesNotExistException,
                IOException

Run the PlanTracker to trigger a Cmd job based on CmdConfig.

Parameters:

cmdConfig - the distributed command job config

jobControlId - job control id for the command

Throws:

JobDoesNotExistException

IOException

getCmdStatus

public Status getCmdStatus(long jobControlId)
                    throws JobDoesNotExistException

Get status information for a CMD.

Parameters:

jobControlId -

Returns:

the Command level status

Throws:

JobDoesNotExistException

findCmdIds

public Set<Long> findCmdIds(List<Status> statusList)
                     throws JobDoesNotExistException

Parameters:

statusList - status list filter

Returns:

cmd ids matching conditions

Throws:

JobDoesNotExistException

findAllFailedPaths

public Set<String> findAllFailedPaths()

Returns:

all failed file paths

findFailedPaths

public Set<String> findFailedPaths(long jobControlId)
                            throws JobDoesNotExistException

Parameters:

jobControlId - jobControlId

Returns:

failed file paths

Throws:

JobDoesNotExistException

getCmdStatusBlock

public CmdStatusBlock getCmdStatusBlock(long jobControlId)
                                 throws JobDoesNotExistException

Get a cmdStatusBlock information.

Parameters:

jobControlId - command id

Returns:

CmdStatusBlock

Throws:

JobDoesNotExistException