alluxio.job.workflow

Class WorkflowExecution

java.lang.Object

alluxio.job.workflow.WorkflowExecution

Direct Known Subclasses:

CompositeExecution

public abstract class WorkflowExecution
extends Object

Execution details of a workflow.

Constructor Summary

Constructors

Constructor and Description
WorkflowExecution() Default constructor.

Method Summary

Modifier and Type	Method and Description
String	getErrorMessage()
long	getLastUpdated()
abstract String	getName()
Status	getStatus()
Set<JobConfig>	next() Given the previous set of jobs were completed successfully, returns a list of jobs to execute next.
protected abstract Set<JobConfig>	nextJobs() Given the previous set of jobs were completed successfully, returns a list of jobs to execute next.
void	stop(Status status, String errorMessage) stops future execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowExecution

public WorkflowExecution()

Default constructor.

Method Detail

getName

public abstract String getName()

Returns:

name of the workflow

next

public final Set<JobConfig> next()

Given the previous set of jobs were completed successfully, returns a list of jobs to execute next. Updating status accordingly.

Returns:

list of JobConfig to execute next, empty when there is no more work

stop

public final void stop(Status status,
                       String errorMessage)

stops future execution.

Parameters:

status - status of the failure: either CANCELLED or FAILED

errorMessage - error message

getStatus

public final Status getStatus()

Returns:

status of the workflow

getLastUpdated

public final long getLastUpdated()

Returns:

the last time status was updated in milliseconds

getErrorMessage

@Nullable
public final String getErrorMessage()

Returns:

the error message

nextJobs

protected abstract Set<JobConfig> nextJobs()

Given the previous set of jobs were completed successfully, returns a list of jobs to execute next.

Returns:

list of JobConfig to execute next, empty when there is no more work