alluxio.job.workflow.composite

Class CompositeExecution

java.lang.Object

alluxio.job.workflow.WorkflowExecution

alluxio.job.workflow.composite.CompositeExecution

public class CompositeExecution
extends WorkflowExecution

Job execution for CompositeConfig.

Constructor Summary

Constructors

Constructor and Description
CompositeExecution(CompositeConfig compositeConfig) Default constructor.

Method Summary

Modifier and Type	Method and Description
String	getName()
protected Set<JobConfig>	nextJobs() Given the previous set of jobs were completed successfully, returns a list of jobs to execute next.

Methods inherited from class alluxio.job.workflow.WorkflowExecution

getErrorMessage, getErrorType, getLastUpdated, getStatus, next, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeExecution

public CompositeExecution(CompositeConfig compositeConfig)

Default constructor.

Parameters:

compositeConfig - the CompositeConfig

Method Detail

getName

public String getName()

Specified by:

getName in class WorkflowExecution

Returns:

name of the workflow

nextJobs

protected Set<JobConfig> nextJobs()

Description copied from class: WorkflowExecution

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

Specified by:

nextJobs in class WorkflowExecution

Returns:

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