Package | Description |
---|---|
org.apache.taverna.activities.dataflow | |
org.apache.taverna.activities.stringconstant |
Contains the activity classes required in the execution of Beanshell scripts.
|
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.processor.activity.impl |
Contains specific implementations of the Activity Ports, together with an implementation of ActivityPortBuilder which is responsible for building them.
|
org.apache.taverna.workflowmodel.processor.dispatch |
Definition and support classes for the Dispatch Stack.
|
org.apache.taverna.workflowmodel.processor.dispatch.impl |
Implementation package for the dispatch stack interfaces.
|
org.apache.taverna.workflowmodel.processor.dispatch.layers |
Contains implementations of DispatchLayer defined by the core Taverna 2
specification.
|
org.apache.taverna.workflowmodel.processor.iteration |
Object model and enactment logic for the iteration strategy component of
a Processor
|
org.apache.taverna.workflowmodel.processor.iteration.impl |
Implementation logic for the iteration system.
|
Modifier and Type | Class and Description |
---|---|
class |
DataflowActivity
An Activity providing nested Dataflow functionality.
|
Modifier and Type | Class and Description |
---|---|
class |
StringConstantActivity
An Activity that holds a constant string value.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Condition
Defines the base interface for a condition which must be satisfied before a
processor can commence invocation.
|
interface |
Configurable<ConfigurationType>
Interface for workflow items that can be configured from a bean.
|
interface |
Dataflow
Top level definition object for a dataflow workflow.
|
interface |
DataflowInputPort
An input port on a Dataflow contains a nested output port within it.
|
interface |
DataflowOutputPort
Output port of a DataFlow, exposes an internal EventHandlingInputPort into
which the internal workflow logic pushes data to be exposed outside the
workflow boundary.
|
interface |
DataflowPort
Defines that the implementing port belongs to a Dataflow
|
interface |
Datalink
A single point to point data link from an instance of
EventForwardingOutputPort to an instance of EventHandlingInputPort
|
interface |
EventForwardingOutputPort
An extension of OutputPort defining a set of target EventReceivingInputPorts
to which internally generated events will be relayed.
|
interface |
EventHandlingInputPort
Input port capable of receiving and reacting to workflow events.
|
interface |
FilteringInputPort
A filtering input port is one capable of filtering events to only pass
through data events at a certain depth.
|
interface |
InputPort
Marker interface denoting that the instance is an input port.
|
interface |
Merge
Allows multiple outputs to be routed to a single input within the dataflow.
|
interface |
MergeInputPort
Input port on a Merge object
|
interface |
MergeOutputPort
An EventForwardingOutputPort that is associated with Merge instances.
|
interface |
MergePort
|
interface |
NamedWorkflowEntity
Entities existing directly within a workflow such as Processors, Merge
operators and other potential future extensions exist within a naming scheme.
|
interface |
OutputPort
Port representing the output of an activity, processor or workflow.
|
interface |
Port
Named port which receives events from some other entity and handles them
appropriately.
|
interface |
Processor
A single node within the dataflow digraph, the Processor is the basic
functional unit within a Taverna workflow.
|
interface |
ProcessorInputPort
Input port on a Processor, is both a filtering input port and a processor
port
|
interface |
ProcessorOutputPort
Input port on a Processor, is both an event forwarding output port and a
processor port
|
interface |
ProcessorPort
|
interface |
TokenProcessingEntity
Superinterface for all classes within the workflow model which consume and
emit workflow data tokens.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractOutputPort
Simple implementation of OutputPort, extends AbstractPort and adds the
granular depth bean getter.
|
class |
AbstractPort
Port definition with depth and name
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventHandlingInputPort
Extends AbstractPort with the getIncomingLink method and an additional
implementation method to set the incoming data link
|
class |
AbstractFilteringInputPort
Abstract superclass for filtering input ports, extend and implement the
pushXXX methods to configure behaviour
|
class |
BasicEventForwardingOutputPort
Extension of AbstractOutputPort implementing EventForwardingOutputPort
|
class |
DataflowImpl
Implementation of Dataflow including implementation of the dataflow level
type checker.
|
class |
DataflowInputPortImpl |
class |
ProcessorImpl
Implementation of Processor
|
Modifier and Type | Interface and Description |
---|---|
interface |
Activity<ConfigurationType>
Defines a single abstract or concrete invokable activity.
|
interface |
ActivityInputPort
Specialisation of InputPort to capture the extra information required by
Activity instances.
|
interface |
ActivityOutputPort
The output port of an
Activity . |
interface |
ActivityPort
The input or output port of an
Activity . |
interface |
AsynchronousActivity<ConfigurationType>
A concrete invokable activity with an asynchronous invocation API and no
knowledge of invocation context.
|
interface |
MonitorableAsynchronousActivity<ConfigType>
An extension of AsynchronousActivity with the additional stipulation that
implementing classes must return a set of monitorable properties for the
activity invocation instance when invoked.
|
interface |
SupersededActivity<ConfigurationType>
A superseded activity is one which has been replaced be another activity type
of similar functionality but different configuration and name
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractActivity<ConfigType>
Convenience abstract superclass for generic Activity instances.
|
class |
AbstractAsynchronousActivity<ConfigType>
Abstract superclass for asynchronous activities.
|
class |
DisabledActivity
A disabled activity is a wrapper for an Activity that is offline or similarly
disabled.
|
class |
NonExecutableActivity<T>
A non-executable activity is a wrapper for an Activity that cannot be
executed, for example because it is offline or unrecognized.
|
class |
UnrecognizedActivity
An unrecognized activity is an activity that was not recognized when the
workflow was opened.
|
Modifier and Type | Class and Description |
---|---|
class |
ActivityInputPortImpl
An input port on an Activity instance.
|
class |
ActivityOutputPortImpl
An output port on an Activity instance, used as a bean to hold port name,
depth and granular depth properties.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DispatchLayer<ConfigurationType>
Layers within the dispatch stack define a control flow to handle dispatch of
jobs from a queue (generated by the iteration system) to appropriate
activities.
|
interface |
DispatchStack
The dispatch stack is responsible for consuming a queue of jobs from the
iteration strategy and dispatching those jobs through a stack based control
flow to an appropriate invocation target.
|
interface |
PropertyContributingDispatchLayer<ConfigType>
Used by dispatch layers which can contribute property information to their
parent processor instance.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDispatchLayer<ConfigurationType>
Convenience abstract implementation of DispatchLayer
|
class |
AbstractErrorHandlerLayer<ConfigurationType>
Superclass of error handling dispatch layers (for example retry and
failover).
|
Modifier and Type | Class and Description |
---|---|
class |
DispatchStackImpl
The dispatch stack is responsible for consuming a queue of jobs from the
iteration strategy and dispatching those jobs through a stack based control
flow to an appropriate invocation target.
|
protected class |
DispatchStackImpl.TopLayer |
Modifier and Type | Class and Description |
---|---|
class |
ErrorBounce
Receives job events, checks to see whether any parameters in the job are
error tokens or collections which contain errors.
|
class |
Failover
Failure handling dispatch layer, consumes job events with multiple activities
and emits the same job but with only the first activity.
|
class |
IntermediateProvenance
Sits above the
Invoke layer and collects information about the
current workflow run to be stored by the ProvenanceConnector . |
class |
Invoke
Context free invoker layer, does not pass index arrays of jobs into activity
instances.
|
class |
Loop
A layer that allows while-style loops.
|
class |
Parallelize
Dispatch layer which consumes a queue of events and fires off a fixed number
of simultaneous jobs to the layer below.
|
class |
Retry
Implements retry policy with delay between retries and exponential backoff
|
class |
Stop
This layer allows for the cancellation, pausing and resuming of workflow
runs.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IterationStrategy |
interface |
IterationStrategyNode
Interface for nodes within an iteration strategy layer
|
interface |
IterationStrategyStack
Stack of iteration strategy containers.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractIterationStrategyNode
Abstract superclass for implementations of IterationStrategyNode, adds logic
to connect nodes together and convenience methods to push jobs and completion
events up to the parent node.
|
class |
CompletionHandlingAbstractIterationStrategyNode
A superclass for all iteration strategy nodes which are required to propagate
final completion events formed from multiple inputs.
|
class |
CrossProduct
A cross product node combines its inputs in an 'all against all' manner.
|
class |
DotProduct
The dot product matches jobs by index array, when a job is received a job is
emited if and only if the index array of the new job is matched exactly by
index arrays of one job in each other input index.
|
class |
NamedInputPortNode
Acts as the input to a stage within the iteration strategy, passes all jobs
straight through.
|
class |
PrefixDotProduct
Matches jobs where the index array of the job on index 0 is the prefix of the
index array of the job on index 1.
|
class |
TerminalNode
The terminal node is the root of the iteration strategy tree, it is
responsible for forwarding all events up to the iteration strategy itself
which can then propogate them to the strategy stack.
|
Modifier and Type | Class and Description |
---|---|
class |
IterationStrategyImpl
A single layer of iteration strategy, consuming individual named inputs and
combining these into Job objects to be consumed by the dispatch stack
|
class |
IterationStrategyImpl.TerminalNodeImpl
The terminal node is used internally as the root of the iteration
strategy tree, it is responsible for forwarding all events up to the
iteration strategy itself which can then propogate them to the strategy
stack.
|
class |
IterationStrategyStackImpl
Contains an ordered list of IterationStrategyImpl objects.
|
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.