Package jline.lang.workflow

Class Workflow

java.lang.Object

jline.lang.Model

jline.lang.workflow.Workflow

All Implemented Interfaces:

Serializable

public class Workflow
extends Model

A computational workflow that can be converted to a phase-type distribution.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Workflow(String name)

Method Summary

Modifier and Type	Method	Description
WorkflowActivity	addActivity(String name, double meanServiceTime)
WorkflowActivity	addActivity(String name, Distribution hostDemand)
void	addPrecedence(ActivityPrecedence prec)
void	addPrecedence(ActivityPrecedence[] precs)
static ActivityPrecedence	AndFork(WorkflowActivity preAct, List<WorkflowActivity> postActs)
static ActivityPrecedence	AndJoin(List<WorkflowActivity> preActs, WorkflowActivity postAct)
static Pair<Matrix,Matrix>	composeParallel(Matrix alpha1, Matrix T1, Matrix alpha2, Matrix T2)
static Pair<Matrix,Matrix>	composeRepeat(Matrix alpha, Matrix T, int count)
static Pair<Matrix,Matrix>	composeSerial(Matrix alpha1, Matrix T1, Matrix alpha2, Matrix T2)
static Workflow	fromWfCommons(String jsonFile)	Load a workflow from a WfCommons JSON file.
static Workflow	fromWfCommons(String jsonFile, WfCommonsOptions options)	Load a workflow from a WfCommons JSON file with options.
List<WorkflowActivity>	getActivities()
WorkflowActivity	getActivity(String name)
List<ActivityPrecedence>	getPrecedences()
static ActivityPrecedence	Loop(WorkflowActivity preAct, List<WorkflowActivity> postActs, double count)
static ActivityPrecedence	OrFork(WorkflowActivity preAct, List<WorkflowActivity> postActs, double[] probs)
static ActivityPrecedence	OrJoin(List<WorkflowActivity> preActs, WorkflowActivity postAct)
static ActivityPrecedence[]	Serial(WorkflowActivity... activities)
APH	toPH()
Pair<Boolean,String>	validate()

Methods inherited from class jline.lang.Model

getName, getVersion, setName, setVersion

Methods inherited from class java.lang.Object

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

Constructor Details

Workflow

public Workflow(String name)

Method Details

addActivity

public WorkflowActivity addActivity(String name,
 double meanServiceTime)

addActivity

public WorkflowActivity addActivity(String name,
 Distribution hostDemand)

addPrecedence

public void addPrecedence(ActivityPrecedence prec)

addPrecedence

public void addPrecedence(ActivityPrecedence[] precs)

getActivity

public WorkflowActivity getActivity(String name)

getActivities

public List<WorkflowActivity> getActivities()

getPrecedences

public List<ActivityPrecedence> getPrecedences()

validate

public Pair<Boolean,String> validate()

toPH

public APH toPH()

composeSerial

public static Pair<Matrix,Matrix> composeSerial(Matrix alpha1,
 Matrix T1,
 Matrix alpha2,
 Matrix T2)

composeParallel

public static Pair<Matrix,Matrix> composeParallel(Matrix alpha1,
 Matrix T1,
 Matrix alpha2,
 Matrix T2)

composeRepeat

public static Pair<Matrix,Matrix> composeRepeat(Matrix alpha,
 Matrix T,
 int count)

Serial

public static ActivityPrecedence[] Serial(WorkflowActivity... activities)

AndFork

public static ActivityPrecedence AndFork(WorkflowActivity preAct,
 List<WorkflowActivity> postActs)

AndJoin

public static ActivityPrecedence AndJoin(List<WorkflowActivity> preActs,
 WorkflowActivity postAct)

OrFork

public static ActivityPrecedence OrFork(WorkflowActivity preAct,
 List<WorkflowActivity> postActs,
 double[] probs)

OrJoin

public static ActivityPrecedence OrJoin(List<WorkflowActivity> preActs,
 WorkflowActivity postAct)

Loop

public static ActivityPrecedence Loop(WorkflowActivity preAct,
 List<WorkflowActivity> postActs,
 double count)

fromWfCommons

public static Workflow fromWfCommons(String jsonFile)
                              throws IOException

Load a workflow from a WfCommons JSON file.

WfCommons (https://github.com/wfcommons/workflow-schema) is a standard format for representing scientific workflow traces.

Parameters:

jsonFile - Path to the WfCommons JSON file

Returns:

Workflow object

Throws:

IOException - If the file cannot be read

fromWfCommons

public static Workflow fromWfCommons(String jsonFile,
 WfCommonsOptions options)
                              throws IOException

Load a workflow from a WfCommons JSON file with options.

Parameters:

jsonFile - Path to the WfCommons JSON file

options - Loader options

Returns:

Workflow object

Throws:

IOException - If the file cannot be read