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.platform.capability.activity.impl | |
org.apache.taverna.platform.capability.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.health |
A package that contains a set of classes to be used in testing a Dataflow prior to invocation.
These can carry our various tests such as a service endpoint being accessible. |
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.dispatch.events | |
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.utils |
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 | Method and Description |
---|---|
Activity<?> |
ActivityServiceImpl.createActivity(URI activityType,
com.fasterxml.jackson.databind.JsonNode configuration) |
Modifier and Type | Method and Description |
---|---|
Activity<?> |
ActivityService.createActivity(URI activityType,
com.fasterxml.jackson.databind.JsonNode configuration)
Returns the activity for the specified activity type.
|
Modifier and Type | Method and Description |
---|---|
Activity<?> |
WorkflowToDataflowMapper.getDataflowActivity(Activity workflowActivity) |
Modifier and Type | Method and Description |
---|---|
Activity |
WorkflowToDataflowMapper.getWorkflowActivity(Activity<?> dataflowActiviy) |
Modifier and Type | Method and Description |
---|---|
Activity<?> |
InvocationStartedProvenanceItem.getActivity() |
Activity<?> |
ActivityProvenanceItem.getActivity() |
Modifier and Type | Method and Description |
---|---|
void |
InvocationStartedProvenanceItem.setActivity(Activity<?> activity) |
void |
ActivityProvenanceItem.setActivity(Activity<?> activity) |
Modifier and Type | Method and Description |
---|---|
List<? extends Activity<?>> |
Processor.getActivityList()
A processor contains zero or more activities in an ordered list.
|
Edit<Activity<?>> |
Edits.getAddActivityInputPortEdit(Activity<?> activity,
ActivityInputPort activityInputPort)
Returns an edit to add an ActivityInputPort to an Activity.
|
Edit<Activity<?>> |
Edits.getAddActivityInputPortMappingEdit(Activity<?> activity,
String processorPortName,
String activityPortName)
Returns an edit to add a ProcessorInputPort to ActivityInputPort mapping
to an Activity.
|
Edit<Activity<?>> |
Edits.getAddActivityOutputPortEdit(Activity<?> activity,
ActivityOutputPort activityOutputPort)
Returns an edit to add an ActivityOutputPort to an Activity.
|
Edit<Activity<?>> |
Edits.getAddActivityOutputPortMappingEdit(Activity<?> activity,
String processorPortName,
String activityPortName)
Returns an edit to add a ProcessorOutputPort to OutputPort mapping to an
Activity.
|
<ConfigurationBean> |
Edits.getConfigureActivityEdit(Activity<ConfigurationBean> activity,
ConfigurationBean configurationBean)
Returns an Edit that is responsible for configuring an Activity with a
given configuration bean.
|
Edit<Activity<?>> |
Edits.getRemoveActivityInputPortEdit(Activity<?> activity,
ActivityInputPort activityInputPort)
Returns an edit to remove an ActivityInputPort from an Activity.
|
Edit<Activity<?>> |
Edits.getRemoveActivityInputPortMappingEdit(Activity<?> activity,
String processorPortName)
Returns an edit to remove a ProcessorInputPort to ActivityInputPort
mapping from an Activity.
|
Edit<Activity<?>> |
Edits.getRemoveActivityOutputPortEdit(Activity<?> activity,
ActivityOutputPort activityOutputPort)
Returns an edit to remove an OutputPort from an Activity.
|
Edit<Activity<?>> |
Edits.getRemoveActivityOutputPortMappingEdit(Activity<?> activity,
String processorPortName)
Returns an edit to remove a ProcessorOutputPort to OutputPort mapping
from an Activity.
|
Modifier and Type | Method and Description |
---|---|
Edit<Processor> |
Edits.getAddActivityEdit(Processor processor,
Activity<?> activity)
Add an Activity implementation to the set of activities within a
Processor
|
Edit<Activity<?>> |
Edits.getAddActivityInputPortEdit(Activity<?> activity,
ActivityInputPort activityInputPort)
Returns an edit to add an ActivityInputPort to an Activity.
|
Edit<Activity<?>> |
Edits.getAddActivityInputPortMappingEdit(Activity<?> activity,
String processorPortName,
String activityPortName)
Returns an edit to add a ProcessorInputPort to ActivityInputPort mapping
to an Activity.
|
Edit<Activity<?>> |
Edits.getAddActivityOutputPortEdit(Activity<?> activity,
ActivityOutputPort activityOutputPort)
Returns an edit to add an ActivityOutputPort to an Activity.
|
Edit<Activity<?>> |
Edits.getAddActivityOutputPortMappingEdit(Activity<?> activity,
String processorPortName,
String activityPortName)
Returns an edit to add a ProcessorOutputPort to OutputPort mapping to an
Activity.
|
<ConfigurationBean> |
Edits.getConfigureActivityEdit(Activity<ConfigurationBean> activity,
ConfigurationBean configurationBean)
Returns an Edit that is responsible for configuring an Activity with a
given configuration bean.
|
Edit<Processor> |
Edits.getRemoveActivityEdit(Processor processor,
Activity<?> activity)
Returns an edit to remove an Activity from a Processor
|
Edit<Activity<?>> |
Edits.getRemoveActivityInputPortEdit(Activity<?> activity,
ActivityInputPort activityInputPort)
Returns an edit to remove an ActivityInputPort from an Activity.
|
Edit<Activity<?>> |
Edits.getRemoveActivityInputPortMappingEdit(Activity<?> activity,
String processorPortName)
Returns an edit to remove a ProcessorInputPort to ActivityInputPort
mapping from an Activity.
|
Edit<Activity<?>> |
Edits.getRemoveActivityOutputPortEdit(Activity<?> activity,
ActivityOutputPort activityOutputPort)
Returns an edit to remove an OutputPort from an Activity.
|
Edit<Activity<?>> |
Edits.getRemoveActivityOutputPortMappingEdit(Activity<?> activity,
String processorPortName)
Returns an edit to remove a ProcessorOutputPort to OutputPort mapping
from an Activity.
|
Modifier and Type | Method and Description |
---|---|
static VisitReport |
RemoteHealthChecker.contactEndpoint(Activity<?> activity,
String endpoint)
Try to contact the specified endpoint as part of the health-checking of
the Activity.
|
Modifier and Type | Field and Description |
---|---|
protected List<Activity<?>> |
ProcessorImpl.activityList |
Modifier and Type | Method and Description |
---|---|
Activity<T> |
AbstractActivityEdit.applyEdit() |
Activity<T> |
AbstractActivityEdit.getSubject() |
Constructor and Description |
---|
AbstractActivityEdit(Activity<T> activity) |
Modifier and Type | Interface and Description |
---|---|
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 | Method and Description |
---|---|
Activity<?> |
ActivityFactory.createActivity()
Creates a new
Activity instance. |
Activity<?> |
DisabledActivity.getActivity() |
Activity<?> |
ActivityAndBeanWrapper.getActivity() |
Activity<?> |
SupersededActivity.getReplacementActivity() |
Modifier and Type | Method and Description |
---|---|
void |
ActivityAndBeanWrapper.setActivity(Activity<?> activity) |
Constructor and Description |
---|
DisabledActivity(Activity<?> activity)
Create a DisabledActivity that represents a specific Activity that is now
disabled e.g.
|
DisabledActivity(Activity<?> activity,
Object config)
Create a DisabledActivity that represents a specific Activity with its
configuration.
|
Constructor and Description |
---|
DisabledActivity(Class<? extends Activity<?>> activityClass,
Object config)
Create a DisabledActivity that represents an offline activity of the
specified class with the specified configuration.
|
Modifier and Type | Method and Description |
---|---|
Activity<?> |
DispatchErrorEvent.getFailedActivity()
Return the Activity instance which failed to produce this error message
|
Modifier and Type | Method and Description |
---|---|
List<? extends Activity<?>> |
DispatchJobQueueEvent.getActivities() |
List<? extends Activity<?>> |
DispatchJobEvent.getActivities()
Returns a list of activity instances which can be applied to the data
contained by this job event.
|
Constructor and Description |
---|
DispatchErrorEvent(String owningProcess,
int[] index,
InvocationContext context,
String errorMessage,
Throwable t,
DispatchErrorType failureType,
Activity<?> failedActivity)
Create a new error event
|
Constructor and Description |
---|
DispatchJobEvent(String owningProcess,
int[] index,
InvocationContext context,
Map<String,T2Reference> data,
List<? extends Activity<?>> activities)
Create a new job event, specifying a complete set of input data and a
list of activities which could potentially consume this data
|
DispatchJobQueueEvent(String owner,
InvocationContext context,
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> queue,
List<? extends Activity<?>> activities)
Create a new job queue event, specifying the queue of Completion and Job
objects and the list of activities which will be used to process the
corresponding dispatch events
|
Modifier and Type | Method and Description |
---|---|
protected abstract List<? extends Activity<?>> |
DispatchStackImpl.getActivities()
Override to return the list of activities to be used by this dispatch
stack.
|
Modifier and Type | Method and Description |
---|---|
Activity<?> |
LoopConfiguration.getCondition() |
Modifier and Type | Method and Description |
---|---|
void |
LoopConfiguration.setCondition(Activity<?> activity) |
Modifier and Type | Method and Description |
---|---|
void |
Parallelize.receiveJob(Job job,
List<? extends Activity<?>> activities) |
Modifier and Type | Method and Description |
---|---|
static ActivityInputPort |
Tools.getActivityInputPort(Activity<?> activity,
String portName) |
static OutputPort |
Tools.getActivityOutputPort(Activity<?> activity,
String portName) |
static ProcessorInputPort |
Tools.getProcessorInputPort(Processor processor,
Activity<?> activity,
InputPort activityInputPort) |
static ProcessorOutputPort |
Tools.getProcessorOutputPort(Processor processor,
Activity<?> activity,
OutputPort activityOutputPort) |
static Collection<Processor> |
Tools.getProcessorsWithActivity(Dataflow dataflow,
Activity<?> activity) |
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.