Package | Description |
---|---|
org.apache.taverna.activities.dataflow | |
org.apache.taverna.facade |
Facade interfaces to represent a workflow instance within the enactor.
|
org.apache.taverna.facade.impl | |
org.apache.taverna.platform.execution.api | |
org.apache.taverna.platform.execution.impl.local | |
org.apache.taverna.provenance.item | |
org.apache.taverna.workflowmodel |
Defines classes and interfaces for workflow level entities and events.
|
org.apache.taverna.workflowmodel.impl |
Implementation package for workflow entities
|
org.apache.taverna.workflowmodel.processor.activity |
Provides definitions for a single Activity to be contained within a
Processor.
|
org.apache.taverna.workflowmodel.utils |
Modifier and Type | Method and Description |
---|---|
Dataflow |
DataflowActivity.getNestedDataflow() |
Modifier and Type | Method and Description |
---|---|
void |
DataflowActivity.setNestedDataflow(Dataflow dataflow) |
Modifier and Type | Method and Description |
---|---|
Dataflow |
WorkflowInstanceFacade.getDataflow()
Return the dataflow this facade facades
|
Modifier and Type | Method and Description |
---|---|
Dataflow |
WorkflowInstanceFacadeImpl.getDataflow() |
Constructor and Description |
---|
FacadeResultListener(Dataflow dataflow,
WorkflowProvenanceItem workflowItem) |
WorkflowInstanceFacadeImpl(Dataflow dataflow,
InvocationContext context,
String parentProcess) |
Modifier and Type | Method and Description |
---|---|
Dataflow |
WorkflowCompiler.getDataflow(Workflow workflow)
Convert a workflow into a dataflow.
|
Dataflow |
WorkflowCompiler.getDataflow(WorkflowBundle bundle)
Convert a workflow bundle into a dataflow.
|
Modifier and Type | Method and Description |
---|---|
protected Dataflow |
WorkflowToDataflowMapper.createDataflow(Workflow workflow) |
Dataflow |
WorkflowToDataflowMapper.getDataflow(Workflow workflow) |
Dataflow |
LocalExecutionService.getDataflow(Workflow workflow) |
Dataflow |
LocalExecutionService.getDataflow(WorkflowBundle bundle) |
Modifier and Type | Method and Description |
---|---|
Workflow |
WorkflowToDataflowMapper.getWorkflow(Dataflow dataflow) |
Modifier and Type | Method and Description |
---|---|
Dataflow |
WorkflowProvenanceItem.getDataflow() |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowProvenanceItem.setDataflow(Dataflow dataflow) |
Modifier and Type | Method and Description |
---|---|
Dataflow |
Edits.createDataflow()
Build a new Dataflow workflow
|
Dataflow |
InvalidDataflowException.getDataflow()
Get the
Dataflow that is not valid. |
Dataflow |
DataflowPort.getDataflow()
Get the parent DataFlow to which this port belongs
|
Modifier and Type | Method and Description |
---|---|
Edit<Dataflow> |
Edits.getAddDataflowInputPortEdit(Dataflow dataflow,
DataflowInputPort dataflowInputPort)
Returns an edit to add a DataflowInputPort to a Dataflow.
|
Edit<Dataflow> |
Edits.getAddDataflowOutputPortEdit(Dataflow dataflow,
DataflowOutputPort dataflowOutputPort)
Returns an edit to add a DataflowOutputPort to a Dataflow.
|
Edit<Dataflow> |
Edits.getAddMergeEdit(Dataflow dataflow,
Merge processor) |
Edit<Dataflow> |
Edits.getAddProcessorEdit(Dataflow dataflow,
Processor processor)
Provides an edit object responsible for adding a Processor to a Dataflow
|
Edit<Dataflow> |
Edits.getCreateDataflowInputPortEdit(Dataflow dataflow,
String portName,
int portDepth,
int granularDepth)
Add an input port to a dataflow.
|
Edit<Dataflow> |
Edits.getCreateDataflowOutputPortEdit(Dataflow dataflow,
String portName)
Add an output port to a dataflow.
|
Edit<Dataflow> |
Edits.getRemoveDataflowInputPortEdit(Dataflow dataflow,
DataflowInputPort dataflowInputPort)
Returns an edit to remove a DataflowInputPort from a Dataflow.
|
Edit<Dataflow> |
Edits.getRemoveDataflowOutputPortEdit(Dataflow dataflow,
DataflowOutputPort dataflowOutputPort)
Returns an edit to remove a DataflowOutputPort from a Dataflow.
|
Edit<Dataflow> |
Edits.getRemoveMergeEdit(Dataflow dataflow,
Merge merge)
Removes a merge from the dataflow.
|
Edit<Dataflow> |
Edits.getRemoveProcessorEdit(Dataflow dataflow,
Processor processor)
Returns an edit to remove a Processor from a Dataflow.
|
Edit<Dataflow> |
Edits.getUpdateDataflowInternalIdentifierEdit(Dataflow dataflow,
String newId) |
Edit<Dataflow> |
Edits.getUpdateDataflowNameEdit(Dataflow dataflow,
String newName) |
Modifier and Type | Method and Description |
---|---|
DataflowInputPort |
Edits.createDataflowInputPort(String name,
int depth,
int granularDepth,
Dataflow dataflow)
Builds a new DataflowInputPort.
|
DataflowOutputPort |
Edits.createDataflowOutputPort(String name,
Dataflow dataflow)
Builds a new DataflowOutputPort.
|
Merge |
Edits.createMerge(Dataflow dataflow) |
WorkflowInstanceFacade |
Edits.createWorkflowInstanceFacade(Dataflow dataflow,
InvocationContext context,
String parentProcess)
Build a new WorkflowInstanceFacade using the supplied Dataflow
|
Edit<Dataflow> |
Edits.getAddDataflowInputPortEdit(Dataflow dataflow,
DataflowInputPort dataflowInputPort)
Returns an edit to add a DataflowInputPort to a Dataflow.
|
Edit<Dataflow> |
Edits.getAddDataflowOutputPortEdit(Dataflow dataflow,
DataflowOutputPort dataflowOutputPort)
Returns an edit to add a DataflowOutputPort to a Dataflow.
|
Edit<Dataflow> |
Edits.getAddMergeEdit(Dataflow dataflow,
Merge processor) |
Edit<Dataflow> |
Edits.getAddProcessorEdit(Dataflow dataflow,
Processor processor)
Provides an edit object responsible for adding a Processor to a Dataflow
|
Edit<Dataflow> |
Edits.getCreateDataflowInputPortEdit(Dataflow dataflow,
String portName,
int portDepth,
int granularDepth)
Add an input port to a dataflow.
|
Edit<Dataflow> |
Edits.getCreateDataflowOutputPortEdit(Dataflow dataflow,
String portName)
Add an output port to a dataflow.
|
Edit<Dataflow> |
Edits.getRemoveDataflowInputPortEdit(Dataflow dataflow,
DataflowInputPort dataflowInputPort)
Returns an edit to remove a DataflowInputPort from a Dataflow.
|
Edit<Dataflow> |
Edits.getRemoveDataflowOutputPortEdit(Dataflow dataflow,
DataflowOutputPort dataflowOutputPort)
Returns an edit to remove a DataflowOutputPort from a Dataflow.
|
Edit<Dataflow> |
Edits.getRemoveMergeEdit(Dataflow dataflow,
Merge merge)
Removes a merge from the dataflow.
|
Edit<Dataflow> |
Edits.getRemoveProcessorEdit(Dataflow dataflow,
Processor processor)
Returns an edit to remove a Processor from a Dataflow.
|
Edit<Dataflow> |
Edits.getUpdateDataflowInternalIdentifierEdit(Dataflow dataflow,
String newId) |
Edit<Dataflow> |
Edits.getUpdateDataflowNameEdit(Dataflow dataflow,
String newName) |
Constructor and Description |
---|
InvalidDataflowException(Dataflow dataflow,
DataflowValidationReport report) |
Modifier and Type | Class and Description |
---|---|
class |
DataflowImpl
Implementation of Dataflow including implementation of the dataflow level
type checker.
|
Modifier and Type | Method and Description |
---|---|
Dataflow |
AbstractDataflowEdit.applyEdit() |
Dataflow |
EditsImpl.createDataflow() |
Dataflow |
DataflowInputPortImpl.getDataflow() |
Dataflow |
AbstractDataflowEdit.getSubject() |
Constructor and Description |
---|
AbstractDataflowEdit(Dataflow dataflow) |
Modifier and Type | Method and Description |
---|---|
Dataflow |
NestedDataflow.getNestedDataflow() |
Dataflow |
NestedDataflowSource.getParentDataflow() |
Modifier and Type | Method and Description |
---|---|
void |
NestedDataflow.setNestedDataflow(Dataflow dataflow) |
Modifier and Type | Method and Description |
---|---|
static boolean |
Tools.addDataflowIdentification(Dataflow dataflow,
String internalId,
Edits edits)
Add the identification of a Dataflow into its identification annotation
chain (if necessary)
|
protected static EventHandlingInputPort |
Tools.findEventHandlingInputPort(List<Edit<?>> editList,
Dataflow dataflow,
InputPort inputPort,
Edits edits)
Find (and possibly create) an EventHandlingInputPort.
|
protected static EventForwardingOutputPort |
Tools.findEventHandlingOutputPort(List<Edit<?>> editList,
Dataflow dataflow,
OutputPort outputPort,
Edits edits)
Find (and possibly create) an EventForwardingOutputPort.
|
static Edit<?> |
Tools.getCreateAndConnectDatalinkEdit(Dataflow dataflow,
EventForwardingOutputPort source,
EventHandlingInputPort sink,
Edits edits)
Creates an Edit that creates a Datalink between a source and sink port
and connects the Datalink.
|
static Edit<?> |
Tools.getCreateAndConnectDatalinkEdit(Dataflow dataflow,
OutputPort outputPort,
InputPort inputPort,
Edits edits)
Get an
Edit that will link the given output port to the given
input port. |
static Processor |
Tools.getFirstProcessorWithActivityInputPort(Dataflow dataflow,
ActivityInputPort targetPort)
Find the first processor that contains an activity that has the given
activity input port.
|
static Processor |
Tools.getFirstProcessorWithActivityOutputPort(Dataflow dataflow,
ActivityOutputPort targetPort) |
static Edit<?> |
Tools.getMoveDatalinkSinkEdit(Dataflow dataflow,
Datalink datalink,
EventHandlingInputPort sink,
Edits edits) |
static List<Processor> |
Tools.getNestedPathForProcessor(Processor processor,
Dataflow dataflow)
Return a path of processors where the last element is this processor and
previous ones are nested processors that contain this one all the way to
the top but excluding the top level workflow as this is only a list of
processors.
|
static Collection<Processor> |
Tools.getProcessorsWithActivity(Dataflow dataflow,
Activity<?> activity) |
static Collection<Processor> |
Tools.getProcessorsWithActivityInputPort(Dataflow dataflow,
ActivityInputPort inputPort) |
static Collection<Processor> |
Tools.getProcessorsWithActivityOutputPort(Dataflow dataflow,
OutputPort outputPort) |
static TokenProcessingEntity |
Tools.getTokenProcessingEntityWithEventForwardingOutputPort(EventForwardingOutputPort port,
Dataflow workflow)
Get the TokenProcessingEntity (Processor, Merge or Dataflow) from the
workflow that contains the given EventForwardingOutputPort.
|
static TokenProcessingEntity |
Tools.getTokenProcessingEntityWithEventHandlingInputPort(EventHandlingInputPort port,
Dataflow workflow)
Get the TokenProcessingEntity (Processor, Merge or Dataflow) from the
workflow that contains the given target EventHandlingInputPort.
|
static String |
Tools.uniqueProcessorName(String preferredName,
Dataflow dataflow)
Find a unique processor name for the supplied Dataflow, based upon the
preferred name.
|
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.