org.trianacode.enactment

Class TrianaExec

java.lang.Object

org.trianacode.enactment.TrianaExec

Direct Known Subclasses:

CommandLineExec

public class TrianaExec
extends java.lang.Object

A class for executing a Triana taskgraph. TrianaExec assumes that each taskgraph invocation will correspond with a single set of output data, and thereby synchronizes multiple invocations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TrianaExec.ExecRun

Field Summary

Fields

Modifier and Type	Field and Description
static long	DATA_SLEEP_TIME the time in milliseconds that the manager threads sleep when waiting for the previous data to be sent/the data to arrive.

Constructor Summary

Constructors

Constructor and Description
TrianaExec(TaskGraph taskgraph) Constructs a TrianaExec to execute a clone of the specified taskgraph.
TrianaExec(Tool tool) Constructs a TrianaExec to execute a clone of the specified tool.

Method Summary

Methods

Modifier and Type	Method and Description
void	dispose() Dispose of the TrianaExec and clean up the threads
java.lang.String	getDummyToolName()
Task	getTask()
TaskGraph	getTaskGraph()
boolean	isFinished()
java.lang.Object[]	run(java.lang.Object[] data) Executes the taskgraph using the specified input data array.
java.lang.Object[]	run(java.lang.Object[] data, boolean unpack) Executes the taskgraph using the specified input data array.
void	setDummyToolName(java.lang.String dummyname) Sets the dummy tool name

Methods inherited from class java.lang.Object

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

Field Detail

DATA_SLEEP_TIME

public static long DATA_SLEEP_TIME

the time in milliseconds that the manager threads sleep when waiting for the previous data to be sent/the data to arrive.

Constructor Detail

TrianaExec

public TrianaExec(TaskGraph taskgraph)
           throws TaskGraphException

Constructs a TrianaExec to execute a clone of the specified taskgraph. Uses a default tool table

Throws:

TaskGraphException

TrianaExec

public TrianaExec(Tool tool)
           throws TaskGraphException

Constructs a TrianaExec to execute a clone of the specified tool. Uses a default tool table.

Throws:

TaskGraphException

Method Detail

getTaskGraph

public TaskGraph getTaskGraph()

Returns:

the taskgraph that is being executed. If a single task was executed then this returns that task wrapped in a simple taskgraph.

getTask

public Task getTask()

Returns:

the task that is being executed.

getDummyToolName

public java.lang.String getDummyToolName()

Returns:

the dummy tool name

setDummyToolName

public void setDummyToolName(java.lang.String dummyname)

Sets the dummy tool name

isFinished

public boolean isFinished()

Returns:

true if the taskgraph has finished executing

run

public java.lang.Object[] run(java.lang.Object[] data)
                       throws TaskGraphException,
                              SchedulerException

Executes the taskgraph using the specified input data array. Automatically unpacks any result data contained in data messages.

Throws:

TaskGraphException

SchedulerException

run

public java.lang.Object[] run(java.lang.Object[] data,
                     boolean unpack)
                       throws TaskGraphException,
                              SchedulerException

Executes the taskgraph using the specified input data array.

Parameters:

unpack - sets whether data within data messages is automatically unpacked in the results array

Throws:

TaskGraphException

SchedulerException

dispose

public void dispose()

Dispose of the TrianaExec and clean up the threads