alluxio.master.job.workflow

Class WorkflowTracker

java.lang.Object

alluxio.master.job.workflow.WorkflowTracker

public class WorkflowTracker
extends Object

The WorkflowTracker.

Constructor Summary

Constructors

Constructor and Description
WorkflowTracker(JobMaster jobMaster) Constructor for WorkflowTracker.

Method Summary

Modifier and Type	Method and Description
boolean	cancel(long jobId) Cancels a job with a particular job id.
void	cleanup(Collection<Long> removedPlanIds) Recursively cleanup the parent workflows given plans to be removed from the PlanTracker.
Set<Long>	findJobs(String name, List<Status> statusList)
Collection<WorkflowInfo>	getAllInfo()
WorkflowInfo	getStatus(long jobId, boolean verbose) Gets information of the given job id.
Collection<Long>	list()
void	onPlanStatusChange(PlanInfo planInfo) Updates internal state of the workflows based on the updated state of a plan.
void	run(WorkflowConfig workflowConfig, long jobId) Runs a workflow with the given configuration and job id.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowTracker

public WorkflowTracker(JobMaster jobMaster)

Constructor for WorkflowTracker.

Parameters:

jobMaster - the job master

Method Detail

run

public void run(WorkflowConfig workflowConfig,
                long jobId)
         throws JobDoesNotExistException,
                ResourceExhaustedException

Runs a workflow with the given configuration and job id.

Parameters:

workflowConfig - the workflow configuration

jobId - the job id

Throws:

JobDoesNotExistException

ResourceExhaustedException

cancel

public boolean cancel(long jobId)

Cancels a job with a particular job id.

Parameters:

jobId - the job id

Returns:

true if job exists, false otherwise

getStatus

public WorkflowInfo getStatus(long jobId,
                              boolean verbose)

Gets information of the given job id.

Parameters:

jobId - the id of the job

verbose - whether the output should be verbose

Returns:

null if the job id isn't know by the workflow tracker. WorkflowInfo otherwise

getAllInfo

public Collection<WorkflowInfo> getAllInfo()

Returns:

all workflow infos

findJobs

public Set<Long> findJobs(String name,
                          List<Status> statusList)

Parameters:

name - job name filter

statusList - status list filter

Returns:

job ids matching conditions

list

public Collection<Long> list()

Returns:

a list of all workflow ids

cleanup

public void cleanup(Collection<Long> removedPlanIds)

Recursively cleanup the parent workflows given plans to be removed from the PlanTracker.

Parameters:

removedPlanIds - the plan ids that are being cleaned up by PlanTracker

onPlanStatusChange

public void onPlanStatusChange(PlanInfo planInfo)

Updates internal state of the workflows based on the updated state of a plan.

Parameters:

planInfo - info of the plan that had its status changed