Package | Description |
---|---|
de.unihalle.informatik.Alida.operator |
Contains the core of Alida, i.e. the operator concept and processing graph stuff.
|
de.unihalle.informatik.Alida.operator.events |
Definitions of Alida events and corresponding reporter and listener interfaces.
|
de.unihalle.informatik.Alida.workflows |
Classes related to workflows in Alida.
|
Modifier and Type | Method and Description |
---|---|
ALDOperator |
ALDOperatorLocation.createOperator()
Create an
ALDOperator form this location object. |
protected ALDWorkflowNode.ALDWorkflowNodeState |
ALDOperatorCollection.OperatorExecutionProxy.getOpState(ALDWorkflowNodeID nid)
Request the state of the operator workflow node.
|
void |
ALDOperator.handleOperatorExecutionProgressEvent(ALDOperatorExecutionProgressEvent event) |
void |
ALDOperatorCollection.OperatorExecutionProxy.nodeParameterChanged()
Notify workflow that operator object parameters changed.
|
void |
ALDOperatorCollection.operatorConfigurationChanged()
Method to notify the collection that configurations of operators
might have changed.
|
Modifier and Type | Method and Description |
---|---|
void |
ALDOperatorExecutionProgressEventListener.handleOperatorExecutionProgressEvent(ALDOperatorExecutionProgressEvent e)
Method which is called on event occurence.
|
Modifier and Type | Method and Description |
---|---|
private boolean |
ALDWorkflow.checkDataflowStateChange(ALDWorkflowNode node)
Updates the state of this node according to the states of its parents.
|
private boolean |
ALDWorkflow.checkLocalStateChange(ALDWorkflowNode node)
Updates the state of this node according to its local configuration.
|
ALDWorkflowNodeID |
ALDWorkflow.copyNode(ALDWorkflowNodeID nodeId,
boolean retainInEdges,
boolean retainParameterValues)
Copy this node.
|
ALDWorkflowEdgeID |
ALDWorkflow.createEdge(ALDWorkflowNodeID sourceNodeId,
String sourceParameterName,
ALDWorkflowNodeID targetNodeId,
String targetParameterName)
This method calls
createEdge with the argument allowDataConversion = false . |
ALDWorkflowEdgeID |
ALDWorkflow.createEdge(ALDWorkflowNodeID sourceNodeId,
String sourceParameterName,
ALDWorkflowNodeID targetNodeId,
String targetParameterName,
Boolean allowDataConversion)
Add an edge representing the data flow between the parameter
sourceParameterName in the operator represented by the node
with sourceNodeId
to the parameter targetParameterName in the operator represented by the node with
targetNodeId . |
ALDWorkflowNodeID |
ALDWorkflow.createNode(ALDOperator op)
Add a new operator to this workflow.
|
ALDWorkflowNodeID |
ALDWorkflow.createNode(ALDOperatorLocation location)
Add a new operator node to this workflow.
|
ALDWorkflowNodeID |
ALDWorkflow.createNode(String opName)
Add a new operator node to this workflow.
|
private void |
ALDWorkflow.directionAllowd(ALDWorkflowNode sourceNode,
ALDOpParameterDescriptor sourceDescriptor,
ALDWorkflowNode targetNode,
ALDOpParameterDescriptor targetDescriptor)
Checks if the direction are allowed
Source parameter
If the source node represents the workflow, the source parameter needs to be of direction IN or
INOUT . |
private void |
ALDWorkflow.edgeAllowed(ALDWorkflowEdge edge,
Boolean allowDataConversion)
Check if this edge is allowed.
|
private static void |
ALDWorkflow.executeNode(ALDWorkflow workflow,
ALDWorkflowNode node,
boolean showResults)
This actually runOps the operator in its own thread
and takes care of firing events for state changes.
|
private void |
ALDWorkflow.executeNonReadyNodes(List<ALDWorkflowNode> nodes,
boolean waitForCompletion)
Run all not ready nodes of the list in the given order.
|
ALDWorkflowEdge |
ALDWorkflow.getEdge(ALDWorkflowEdgeID edgeId)
Get the workflow edge associated with
edgeId . |
Collection<String> |
ALDWorkflow.getMissingRequiredInputs(ALDWorkflowNodeID nodeId)
Returns the names of all required input parameters of the operator object associated with the node
which are not linked and have a value of null.
|
ALDWorkflowNode |
ALDWorkflow.getNode(ALDWorkflowNodeID nodeId)
Get the workflow node associated with
nodeId . |
ALDOperator |
ALDWorkflow.getOperator(ALDWorkflowNodeID nodeId)
Get the operator associated with
nodeId . |
ALDWorkflowNodeID |
ALDWorkflow.getSourceNodeId(ALDWorkflowEdgeID edgeId)
Return the NodeId of the source node of this edge
|
String |
ALDWorkflow.getSourceParameterName(ALDWorkflowEdgeID edgeId)
Return the source parameter name of this edge
|
ALDWorkflowNode.ALDWorkflowNodeState |
ALDWorkflow.getState(ALDWorkflowNodeID nodeId)
Get the state of node with
nodeId . |
ALDWorkflowNodeID |
ALDWorkflow.getTargetNodeId(ALDWorkflowEdgeID edgeId)
Return the NodeId of the target node of this edge
|
String |
ALDWorkflow.getTargetParameterName(ALDWorkflowEdgeID edgeId)
Return the target parameter name of this edge
|
void |
ALDWorkflow.handleOperatorExecutionProgressEvent(ALDOperatorExecutionProgressEvent e) |
static ALDWorkflow |
ALDWorkflow.load(File file)
Load a workflow from
File and create a new workflow object. |
static ALDWorkflow |
ALDWorkflow.load(File file,
boolean doFireEvent)
Load a workflow from
File and create a new workflow object. |
static ALDWorkflow |
ALDWorkflow.load(String filename)
Load a workflow from file with
filename and create a new workflow object. |
static ALDWorkflow |
ALDWorkflow.load(String filename,
boolean doFireEvent)
Load a workflow from file with
filename and create a new workflow object. |
void |
ALDWorkflow.nodeParameterChanged(ALDWorkflowNodeID nodeId)
Notify the workflow that parameters of the operator object associated with node
nodeId have changed. |
void |
ALDWorkflow.redirectSource(ALDWorkflowEdgeID edgeId,
ALDWorkflowNodeID newSourceNodeId,
String newSourceParameterName)
Call
redirectSource with with the argument allowDataConversion = false . |
void |
ALDWorkflow.redirectSource(ALDWorkflowEdgeID edgeId,
ALDWorkflowNodeID newSourceNodeId,
String newSourceParameterName,
Boolean allowDataConversion)
Redirect the source of an edge.
|
void |
ALDWorkflow.redirectTarget(ALDWorkflowEdgeID edgeId,
ALDWorkflowNodeID newTargetNodeId,
String newTargetParameterName)
Calls
redirectTarget with the argument allowDataConversion = false
The same restrictions as for createEdge apply. |
void |
ALDWorkflow.redirectTarget(ALDWorkflowEdgeID edgeId,
ALDWorkflowNodeID newTargetNodeId,
String newTargetParameterName,
Boolean allowDataConversion)
Redirect the target of an edge.
|
void |
ALDWorkflow.removeEdge(ALDWorkflowEdgeID edgeId)
Remove an edge from the workflow.
|
void |
ALDWorkflow.removeNode(ALDWorkflowNodeID nodeId)
Remove a node with all incoming and outgoing edges from the workflow.
|
(package private) void |
ALDWorkflowNode.resetParameter(String parameterName)
Reset the parameter
parameterName in the operator associated to
this node. |
void |
ALDWorkflow.runFromNode(ALDWorkflowNodeID nodeId)
Run the given node and all descendants of the given node.
|
void |
ALDWorkflow.runFromNode(ALDWorkflowNodeID nodeId,
boolean waitForCompletion)
Run the given node and all descendants of the given node.
|
void |
ALDWorkflow.runFromNode(ALDWorkflowNodeID nodeId,
boolean waitForCompletion,
boolean stepRecursively)
Run the given node and all descendants of the given node.
|
void |
ALDWorkflow.runNode(ALDWorkflowNodeID nodeId)
Run the given node and all its ancestors.
|
void |
ALDWorkflow.runNode(ALDWorkflowNodeID nodeId,
boolean waitForCompletion)
Run the given node and all its ancestors.
|
void |
ALDWorkflow.runNode(ALDWorkflowNodeID nodeId,
boolean waitForCompletion,
boolean stepRecursively)
Run the given node and all its ancestors.
|
void |
ALDWorkflow.runWorkflow()
Run the complete workflow.
|
void |
ALDWorkflow.runWorkflow(boolean waitForCompletion)
Run the complete workflow.
|
void |
ALDWorkflow.runWorkflow(boolean waitForCompletion,
boolean stepRecursively)
Run the complete workflow.
|
void |
ALDWorkflow.save(File file)
Save this workflow to file.
|
void |
ALDWorkflow.save(File file,
boolean doFireEvent)
Save this workflow to file.
|
void |
ALDWorkflow.save(String filename)
Save this workflow to file.
|
void |
ALDWorkflow.save(String filename,
boolean doFireEvent)
Save this workflow to file.
|
protected void |
ALDWorkflowNode.setOperator(ALDOperator newOp)
Sets the operator associated with this node.
|
void |
ALDWorkflow.setOperator(ALDWorkflowNodeID nodeId,
ALDOperator newOp)
Set the operator associated with
nodeId . |
(package private) LinkedList<ALDWorkflowNode> |
ALDWorkflow.topSort()
Topologically sorts all nodes of the workflow.
|
(package private) LinkedList<ALDWorkflowNode> |
ALDWorkflow.topSort(Collection<ALDWorkflowNode> nodes)
Topologically sorts the nodes given in
nodes . |
private void |
ALDWorkflow.updateState(ALDWorkflowNode node)
Convenience method which just invokes
ALDWorkflow.updateStates(Collection, boolean) with the single
node . |
private void |
ALDWorkflow.updateStates(Collection<ALDWorkflowNode> nodesToCheck,
boolean doFireEvent)
Updates the states of
nodesToCheck and their descendants. |
Copyright © 2010–2021 Martin Luther University Halle-Wittenberg, Institute of Computer Science, Pattern Recognition and Bioinformatics. All rights reserved.