class |
AbstractConnectedControlActor |
Ancestor for all actors that control (connected) sub-actors in some way.
|
class |
AbstractContainerUpdater |
Ancestor for control actors that update a specific value of a container
using the defined sub-actors.
|
class |
AbstractControlActor |
Ancestor for all actors that control sub-actors in some way.
|
class |
AbstractDataContainerFileChecker<T extends DataContainer> |
Abstract ancestor for transformers that check data container files
whether they are consistents before passing on the file/file arrays.
|
class |
AbstractDirectedControlActor |
Ancestor for all actors that control sub-actors in some way.
|
class |
AbstractDirector |
Manages the execution of actors.
|
class |
AbstractTee |
Abstract ancestor for actors that tee-off tokens.
|
class |
ArrayGenerate |
Applies all sub-actors to the input token and generates an array from the collected output.
Each of the branches is expected to produce at most one output token (ideally one per branch, otherwise there will be null elements in the output array).
|
class |
ArrayProcess |
Applies all sub-actors to each of the array elements.
|
class |
Branch |
Branches off the flow into several sub-branches, each being supplied with a copy of the same object being passed into this meta-actor.
|
class |
CollectionProcess |
Applies all sub-actors to each of the collection elements.
|
class |
ConditionalSequence |
The sequence gets only executed if the condition holds true.
|
class |
ConditionalSubProcess |
Encapsulates a sequence of flow items.
|
class |
ConditionalTee |
Tees off the tokens if the condition evaluates to 'true'.
|
class |
ConditionalTrigger |
Executes the tee-actor whenever a token gets passed through.
|
class |
ContainerValuePicker |
Picks a named value from any container object and tees it off.
With the 'switch-outputs' option it is possible to forward the named value and teeing off the container instead.
If 'ignore missing' is turned off, any value that cannot be found will generate an error logging message and, in case of switched outputs, an actual error.
|
class |
Count |
Counts the number of tokens that pass through and meet the condition and tees off the current count every n-th token.
|
class |
Flow |
Container object for actors, used for executing a flow.
|
class |
IfStorageValue |
An If-Then-Else source actor for storage values.
|
static class |
IfStorageValue.IfStorageValueDirector |
A specialized director for an IfStorageValue control actor.
|
class |
IfThenElse |
Emulates an If-Then-Else construct.
|
static class |
IfThenElse.IfThenElseDirector |
A specialized director for an AbstractIfThenElse control actor.
|
class |
InputOutputListener |
Listens to the input/output tokens of the sub-actors, sending them to callable actors.
|
class |
JMap |
Runs jmap whenever a token gets passed through.
|
class |
LaunchTee |
Launches the sub-flow in a separate thread each time a token arrives.
Internally, a adams.flow.control.LocalScopeTee is used to manage the scope and forward the token.
|
class |
LaunchTrigger |
Launches the sub-flow in a separate thread each time a token arrives.
Internally, a adams.flow.control.LocalScopeTrigger is used to manage the scope.
|
class |
LoadBalancer |
Runs the specified 'load actor' in as many separate threads as specified with the 'num-threads' parameter.
Always uses a copy of the variables.
NB: no callable transformer or sink allowed.
|
class |
LocalScopeSubProcess |
Provides a local scope for the sub-actors.
It is possible to 'propagate' or 'leak' variables and storage items from within the local scope back to the output scope.
|
class |
LocalScopeTee |
Executes the sub-actors whenever a token gets passed through, just like the adams.flow.control.Tee actor, but also provides its own scope for variables and internal storage.
It is possible to 'propagate' or 'leak' variables and storage items from within the local scope back to the output scope.
|
class |
LocalScopeTransformer |
Provides a local scope for the sub-actors.
It is possible to 'propagate' or 'leak' variables and storage items from within the local scope back to the output scope.
|
class |
LocalScopeTrigger |
Executes the sub-actors whenever a token gets passed through, just like the adams.flow.control.Trigger actor, but also provides its own scope for variables and internal storage.
It is possible to 'propagate' or 'leak' variables and storage items from within the local scope back to the output scope.
|
class |
MissionControl |
Displays a control panel for pausing/resuming/stopping the flow.
Useful when executing flows from command-line with the flow runner, offering a minimal control interface.
|
class |
MutableConnectedControlActor |
Abstract superclass for actors that allow their sub-actors to modified
(adding, removing, editing).
|
class |
MutableControlActor |
Abstract superclass for actors that allow their sub-actors to modified
(adding, removing, editing).
|
class |
Once |
Tees off a token only once to its sub-actors.
However, this can be reset when the monitored variable changes.
|
class |
PlotContainerUpdater |
Applies all sub-actors to process either the selected value of the plot container.
|
class |
Rejector |
Rejects data containers with errors attached.
|
class |
RemoteExecutionTrigger |
Transfers the actors below itself, the specified storage items and variables using the specified connection for remote execution.
Uses the adams.scripting.command.flow.RemoteFlowExecution remote command behind the scenes.
|
class |
Sequence |
Encapsulates a sequence of flow items.
|
class |
SequentialDirector |
Manages the execution of actors in sequential order.
|
class |
SinkReset |
Resets all sub-actors in case the monitored variable changed since the last execution.
|
class |
SourceReset |
Resets all sub-actors in case the monitored variable changed since the last execution.
|
class |
StorageValueSequence |
After executing a sequence of actors, the stored item is forwarded in the flow.
|
class |
SubProcess |
Encapsulates a sequence of flow items.
|
static class |
SubProcess.SubProcessDirector |
A specialized director for the SubProcess actor.
|
class |
Switch |
Emulates a Switch control statement.
|
static class |
Switch.SwitchDirector |
A specialized director for the Switch control actor.
|
class |
Tee |
Allows to tap into the flow and tee-off tokens.
|
class |
TimedSubProcess |
Encapsulates a sequence of flow items.
|
class |
TimedTee |
Allows to tap into the flow and tee-off tokens.
Times how long the sub-flow execution takes and sends the time in milli-seconds (as double) in a adams.flow.container.TimingContainer container to the specified callable actor.
|
class |
TimedTrigger |
Executes the subs-actors whenever a token gets passed through.
|
class |
TransformerReset |
Resets all sub-actors in case the monitored variable changed since the last execution.
|
class |
Trigger |
Executes the tee-actor whenever a token gets passed through.
|
class |
TriggerOnce |
Triggers the sub-flow only once.
However, this can be reset when the monitored variable changes.
|
class |
TryCatch |
Safe-guards the execution of the 'try' sequence of actors.
|
class |
UpdateContainerValue |
Applies all sub-actors to process the specified value of the container passing through.
|
class |
UpdateProperties |
Updates the properties of the sub-actor using the values associated with the specfiied variables.
|
class |
WhileLoop |
Emulates a while-loop.
|