class |
AbstractArrayProvider |
Ancestor for source actors that can output items one by one or as a single
array.
|
class |
AbstractBufferingSource |
Ancestor for queues that need to buffer output from eg another process.
|
class |
AbstractConditionalIdSupplier |
Abstract ancestor for ID suppliers that use a conditions object.
|
class |
AbstractDatabaseIdSupplier |
Abstract ancestor for ID suppliers.
|
class |
AbstractDatabaseMetaData |
Ancestor for sources that output the database meta-data.
|
class |
AbstractDbArrayProvider |
Ancestor for array providers that use the database.
|
class |
AbstractDbSource |
Ancestor for sources that access the database..
|
class |
AbstractForLoop |
Abstract ancestor for for-loops.
|
class |
AbstractIdSupplier |
Abstract ancestor for ID suppliers.
|
class |
AbstractInstrumentSupplier |
Abstract ancestor for instrument suppliers.
|
class |
AbstractInteractiveArrayProvider |
Ancestor for interactive sources that can provide the output as an array
or one-by-one.
|
class |
AbstractInteractiveSource |
Ancestor for source actors that interact with the user.
|
class |
AbstractListTables |
Ancestor for sources that list tables from a database.
|
class |
AbstractPythonExecution |
Ancestor for sources that execute a Python executable.
|
class |
AbstractScript |
Ancestor for source script actors.
|
class |
AbstractSelectObjects |
Ancestor for sources that promp the user to select a number of objects to
be broadcasted as tokens.
|
class |
AbstractSimpleDbSource |
Ancestor for simple sources that use the database.
|
class |
AbstractSimpleSource |
Ancestor for sources that just output a single token.
|
class |
AbstractSimpleSourceWithPropertiesUpdating |
Ancestor for simple sources that allow changing the object's properties
using variables.
|
class |
AbstractSpreadSheetDbReader |
Ancestor for spreadsheet database readers.
|
class |
AbstractWekaSetupGenerator<T> |
Abstract ancestor for setup generator sources.
|
class |
ColorProvider |
Uses the configured color provider to generate a number of colors.
|
class |
CombineArrays |
Combines the storage items representing arrays into a single array.
When not supplying an array class the type of the first array is used.
|
class |
CombineCollections |
class |
CombineStorage |
Outputs the expanded string generated from the specified combination expression (variables and storage placeholders).
|
class |
CombineVariables |
Outputs the expanded string generated from the specified combination expression.
|
class |
Command |
Runs an external system command and broadcasts the generated output (stdout and/or stderr) continuously, opposed to adams.flow.source.Exec which waits for the command to finish.
See also:
adams.flow.source.Exec
Input/output:
- generates:
java.lang.String
|
class |
Counter |
Outputs the specified counter as spreadsheet, with two columns: 'Key' and 'Count'.
|
class |
CurrentFlow |
Outputs the current flow, i.e., itself.
|
class |
CurrentTime |
class |
DatabaseMetaData |
Outputs the meta-data of the current database connection.
|
class |
DeQueue |
Polls the specified queue in internal storage for an item, blocks till an item is available.
NB: The user needs to stop the flow as the DeQueue source will never stop, as it assumes that there will be more data coming through.
|
class |
DirectoryLister |
Returns the contents of a directory (files/dirs).
|
class |
DirectorySupplier |
Supplies directories.
|
class |
DumpStorage |
Outputs the storage names and the string representation of their associated values in the specified format.
|
class |
DumpVariables |
Outputs the variable names and their associated values in the specified format.
|
class |
EnterManyValues |
Pops up a dialog, prompting the user to enter one or more values.
|
class |
EnterValue |
Pops up a dialog, prompting the user to enter a value.
|
class |
Exec |
Runs an external system command and broadcasts the generated output (stdout or stderr).
See also:
adams.flow.source.Exec
Input/output:
- generates:
java.lang.String
|
class |
FilenameGenerator |
Uses the specified filename generator to output a filename.
NB: Generators that require an object to pass through won't work with this source.
See also:
adams.flow.transformer.FilenameGenerator
Input/output:
- generates:
java.lang.String
|
class |
FileSupplier |
Supplies files.
|
class |
FileSystemSearch |
Uses the specified search algorithm to perform a file system search and returns the located items.
|
class |
ForLoop |
Emulates the following for-loop for integer IDs:
- positive step size:
for (int i = lower; i <= upper; i += step)
- negative step size:
for (int i = upper; i >= lower; i += step)
The integers can be output as a single array as well.
|
class |
FTPLister |
Deprecated.
|
class |
GetEnvironmentVariable |
Outputs the value of the specified environment variable.
|
class |
GetSystemProperty |
Outputs the value of the specified Java system property.
|
class |
HashSet |
Outputs the specified hashset as spreadsheet, with one column called 'Value' by default.
|
class |
HttpRequest |
Submits the (optional) form parameters to the specified URL and forwards the retrieved HTML as text.
Cookies can be retrieved and stored in internal storage, to be re-used with the next request.
|
class |
Idle |
Simulates an endless loop, which only exits if the flow is stopped.
Essentially blocking any following actors, never outputs anything.
|
class |
InputStreamGenerator |
Uses the specified generator to instantiate an input stream instance.
See also:
adams.flow.sink.CloseInputStream
Input/output:
- generates:
java.io.InputStream
|
class |
IntegerRange |
Outputs the integers defined by the range expression.
|
class |
LargeObjectDbReader |
Allows reading of large objects from a SQL database.
|
class |
ListCallableActors |
class |
ListEnvironmentVariables |
Outputs the names of the currently set environment variables.
|
class |
ListStorageNames |
Outputs the names of the currently available storage items.
|
class |
ListSystemProperties |
Outputs the names of the currently set Java system properties.
|
class |
ListTables |
Lists tables of the current database connection.
|
class |
ListVariables |
Outputs the names of the currently available variables.
|
class |
LookUp |
Forwards the value associated with the given key, using the specified lookup table from internal storage.
|
class |
LookUpTable |
Outputs the specified lookup table as spreadsheet, containing to columns: Key with the keys and Value with the associated values.
|
class |
MakeContainer |
Assembles a container with data obtained from either callable actors or storage items.
|
class |
MathExpression |
Evaluates a mathematical expression.
Variables are supported as well, e.g.: pow(X,@{exp}) with '@{exp}' being a variable available at execution time.
The following grammar is used for the expressions:
expr_list ::= '=' expr_list expr_part | expr_part ;
expr_part ::= expr ;
expr ::= ( expr )
# data types
| number
| string
| boolean
| date
# constants
| true
| false
| pi
| e
| now()
| today()
# negating numeric value
| -expr
# comparisons
| expr < expr
| expr <= expr
| expr > expr
| expr >= expr
| expr = expr
| expr != expr (or: expr <> expr)
# boolean operations
| ! expr (or: not expr)
| expr & expr (or: expr and expr)
| expr | expr (or: expr or expr)
| if[else] ( expr , expr (if true) , expr (if false) )
| ifmissing ( variable , expr (default value if variable is missing) )
| isNaN ( expr )
# arithmetics
| expr + expr
| expr - expr
| expr * expr
| expr / expr
| expr ^ expr (power of)
| expr % expr (modulo)
;
# numeric functions
| abs ( expr )
| sqrt ( expr )
| cbrt ( expr )
| log ( expr )
| log10 ( expr )
| exp ( expr )
| sin ( expr )
| sinh ( expr )
| cos ( expr )
| cosh ( expr )
| tan ( expr )
| tanh ( expr )
| atan ( expr )
| atan2 ( exprY , exprX )
| hypot ( exprX , exprY )
| signum ( expr )
| rint ( expr )
| floor ( expr )
| pow[er] ( expr , expr )
| ceil ( expr )
| min ( expr1 , expr2 )
| max ( expr1 , expr2 )
| year ( expr )
| month ( expr )
| day ( expr )
| hour ( expr )
| minute ( expr )
| second ( expr )
| weekday ( expr )
| weeknum ( expr )
# string functions
| substr ( expr , start [, end] )
| left ( expr , len )
| mid ( expr , start , len )
| right ( expr , len )
| rept ( expr , count )
| concatenate ( expr1 , expr2 [, expr3-5] )
| lower[case] ( expr )
| upper[case] ( expr )
| trim ( expr )
| matches ( expr , regexp )
| trim ( expr )
| len[gth] ( str )
| find ( search , expr [, pos] )
| replace ( str , pos , len , newstr )
| substitute ( str , find , replace [, occurrences] )
;
Notes:
- Variables are either all upper case letters (e.g., "ABC") or any character apart from "]" enclosed by "[" and "]" (e.g., "[Hello World]").
- 'start' and 'end' for function 'substr' are indices that start at 1.
- Index 'end' for function 'substr' is excluded (like Java's 'String.substring(int,int)' method)
- Line comments start with '#'.
- Semi-colons (';') or commas (',') can be used as separator in the formulas,
e.g., 'pow(2,2)' is equivalent to 'pow(2;2)'
- dates have to be of format 'yyyy-MM-dd' or 'yyyy-MM-dd HH:mm:ss'
- times have to be of format 'HH:mm:ss' or 'yyyy-MM-dd HH:mm:ss'
- the characters in square brackets in function names are optional:
e.g.
|
class |
MemoryUsage |
Outputs the memory usage.
The generated map has the following keys:
- init_heap
- max_heap
- used_heap
- committed_heap
- init_non_heap
- max_non_heap
- used_non_heap
- committed_non_heap
Input/output:
- generates:
java.util.Map
|
class |
ModuleInfo |
Outputs a spreadsheet with information about modules available.
|
class |
NewArray |
Generates a new array of the specified class with the given dimensions.
Dimensions are given as follows: [x], with x being the number of elements.
|
class |
NewCollection |
Generates a new (and empty) collection of the specified type.
|
class |
NewDOMDocument |
Creates a new DOM document, e.g., for assembling XML files.
|
class |
NewFlow |
Outputs the flow generated by the specified template.
|
class |
NewImage |
Generates an empty image with the specified dimensions (Type: RGB or ARBG).
|
class |
NewJsonStructure |
Generates an empty JSON data structure of the specified type.
|
class |
NewList |
Generates a list string based on the items produced by the generator and the specified separator.
|
class |
NewMap |
Generates a new java.util.Map object using the specified implementation class.
|
class |
NewMat5File |
Creates an empty Mat5File object.
|
class |
NewMat5Matrix |
Creates a new Matlab matrix.
|
class |
NewMat5Struct |
class |
NewProperties |
Generates a new Properties object.
|
class |
NewRemoteCommand |
Configures and forwards a remote command.
|
class |
NewReport |
Generates a new instance of the specified report class.
|
class |
NewSpreadSheet |
Generates an empty spreadsheet.
|
class |
NewTempFile |
class |
Null |
Dummy source, generates no output.
|
class |
OpenCVDeviceFrameGrabber |
Grabs frames from the specified device and forwards them as image containers.
|
class |
OptionProducer |
Generates string output from the current flow using the specified option producer.
|
class |
OptionTraverser |
Traverses the options of the flow at run-time.
Used for debugging purposes.
|
class |
PasteFromClipboard |
Pops up a dialog, prompting the user to accept content from clipboard.
|
class |
PDFNewDocument |
Creates an empty PDF document.
Needs to be finalized with adams.flow.sink.PDFCloseDocument.
The output of this source can be processed by adams.flow.transformer.PDFAppendDocument.
See also:
adams.flow.transformer.PDFAppendDocument
adams.flow.sink.PDFCloseDocument
Input/output:
- generates:
adams.flow.transformer.pdfproclet.PDFGenerator
|
class |
PipExec |
Executes pip with the specified options and broadcasts the generated output (stdout and/or stderr) continuously.
|
class |
PyroSource |
Generates data using a Pyro4 call
For more information see:
https://pythonhosted.org/Pyro4/
https://github.com/irmen/Pyrolite
Input/output:
- generates:
java.lang.Object
|
class |
PythonExec |
Executes the specified Python script with the specified options and broadcasts the generated output (stdout and/or stderr) continuously.
|
class |
PythonVenvExec |
Executes the specified executable in a Python virtual environment with the specified options and broadcasts the generated output (stdout and/or stderr) continuously.
Fails if the specified environment does not contain any 'activate' scripts typically found in such directories.
|
class |
RandomNumberGenerator |
Random number generator.
|
class |
ReaderGenerator |
Uses the specified generator to instantiate a reader instance.
See also:
adams.flow.sink.CloseReader
Input/output:
- generates:
java.io.InputStream
|
class |
RSync |
Supports synchronization using rsync.
In case of an error, the stderr output is forwarded, otherwise stdout output.
|
class |
Rsync4jRsyncBinary |
Outputs the rsync binary used by the rsync4j library.
|
class |
Rsync4jSshBinary |
Outputs the ssh binary used by the rsync4j library.
|
class |
SelectCharset |
Prompts the user to select a character set.
|
class |
SelectDateTime |
Pops up a dialog, prompting the user to select a date/time, date or time value.
|
class |
SelectDirectory |
Pops up a directory chooser dialog, prompting the user to select a directory.
|
class |
SelectFile |
Pops up a file chooser dialog, prompting the user to select one or more files.
|
class |
SelectObjects |
Allows the user to select an arbitrary number of objects from the specified class hierarchy using the GenericObjectArray.
It is possible to use this dialog for other objects as well that don't belong to a class hierarchy, e.g., adams.core.base.BaseString.
|
class |
SimpleRSync |
An rsync wrapper with a reduced set of options.
|
class |
Socket |
Listens on the specified port for incoming data.
Can either output raw byte arrays or strings (using the specified encoding).
See also:
adams.flow.sink.Socket
Input/output:
- generates:
byte[]
|
class |
SpecifiedActor |
Outputs the actor identified by the actor path.
|
class |
SpreadSheetDbReader |
Returns a spreadsheet object generated from an SQL query.
To optimize memory consumption, you can return the result of the query in chunks of a specified size.
|
class |
SQLIdSupplier |
Executes an SQL statement for generating the IDs.
Variables are automatically expanded.
|
class |
SSHExec |
Runs a system command via ssh on a remote machine and broadcasts the generated output (stdout or stderr).
For more information see:
(2011).
|
class |
Start |
Outputs merely a NullToken.
|
class |
StorageForLoop |
Emulates the following for-loop:
- positive step size:
for (int i = lower; i <= upper; i += step)
- negative step size:
for (int i = upper; i >= lower; i += step)
In each iteration, the specified variable gets updated with the current value of the for-loop variable.
|
class |
StorageValue |
Outputs the value associated with the specified name from temporary storage.
Does nothing if the storage value isn't present.
By supplying a cache name, the value can be obtained from a LRU cache instead of the regular storage.
|
class |
StorageValuesArray |
Outputs the values associated with the specified names from temporary storage as an array.
|
class |
StringConstants |
A source for strings.
|
class |
StringExpression |
Evaluates a string expression.
Variables are supported as well, e.g.: pow(X,@{exp}) with '@{exp}' being a variable available at execution time.
The following grammar is used for the expressions:
expr_list ::= '=' expr_list expr_part | expr_part ;
expr_part ::= expr ;
expr ::= ( expr )
# data types
| number
| string
| boolean
| date
# constants
| true
| false
| pi
| e
| now()
| today()
# negating numeric value
| -expr
# comparisons
| expr < expr
| expr <= expr
| expr > expr
| expr >= expr
| expr = expr
| expr != expr (or: expr <> expr)
# boolean operations
| ! expr (or: not expr)
| expr & expr (or: expr and expr)
| expr | expr (or: expr or expr)
| if[else] ( expr , expr (if true) , expr (if false) )
| ifmissing ( variable , expr (default value if variable is missing) )
| isNaN ( expr )
# arithmetics
| expr + expr
| expr - expr
| expr * expr
| expr / expr
| expr ^ expr (power of)
| expr % expr (modulo)
;
# numeric functions
| abs ( expr )
| sqrt ( expr )
| cbrt ( expr )
| log ( expr )
| log10 ( expr )
| exp ( expr )
| sin ( expr )
| sinh ( expr )
| cos ( expr )
| cosh ( expr )
| tan ( expr )
| tanh ( expr )
| atan ( expr )
| atan2 ( exprY , exprX )
| hypot ( exprX , exprY )
| signum ( expr )
| rint ( expr )
| floor ( expr )
| pow[er] ( expr , expr )
| ceil ( expr )
| min ( expr1 , expr2 )
| max ( expr1 , expr2 )
| year ( expr )
| month ( expr )
| day ( expr )
| hour ( expr )
| minute ( expr )
| second ( expr )
| weekday ( expr )
| weeknum ( expr )
# string functions
| substr ( expr , start [, end] )
| left ( expr , len )
| mid ( expr , start , len )
| right ( expr , len )
| rept ( expr , count )
| concatenate ( expr1 , expr2 [, expr3-5] )
| lower[case] ( expr )
| upper[case] ( expr )
| trim ( expr )
| matches ( expr , regexp )
| trim ( expr )
| len[gth] ( str )
| find ( search , expr [, pos] )
| replace ( str , pos , len , newstr )
| substitute ( str , find , replace [, occurrences] )
# array functions
| len[gth] ( array )
| get ( array , index )
;
Notes:
- Variables are either all upper case letters (e.g., "ABC") or any character apart from "]" enclosed by "[" and "]" (e.g., "[Hello World]").
- 'start' and 'end' for function 'substr' are indices that start at 1.
- 'index' for function 'get' starts at 1.
- Index 'end' for function 'substr' is excluded (like Java's 'String.substring(int,int)' method)
- Line comments start with '#'
- Semi-colons (';') or commas (',') can be used as separator in the formulas,
e.g., 'pow(2,2)' is equivalent to 'pow(2;2)'
- dates have to be of format 'yyyy-MM-dd' or 'yyyy-MM-dd HH:mm:ss'
- times have to be of format 'HH:mm:ss' or 'yyyy-MM-dd HH:mm:ss'
- the characters in square brackets in function names are optional:
e.g.
|
class |
SwitchedSource |
class |
TimeseriesDbReader |
Outputs timeseries containers generated from an SQL SELECT statement.
A new container is started, whenever the value of the ID column changes (hence you need to ensure that the data is ordered on this column).
|
class |
URLSupplier |
Supplies multiple URLs (uniform resource locators).
|
class |
Variable |
Outputs the string value of the specified variable.
Does nothing if the variable hasn't been set.
|
class |
VariablesArray |
Outputs the values associated with the specified variable names as a string array.
|
class |
WekaAssociatorSetup |
Outputs an instance of the specified associator.
|
class |
WekaClassifierGenerator |
Generates multiple classifier setups.
|
class |
WekaClassifierSetup |
Outputs an instance of the specified classifier.
|
class |
WekaClustererGenerator |
Generates multiple clusterer setups.
|
class |
WekaClustererSetup |
Outputs an instance of the specified clusterer.
|
class |
WekaDatabaseReader |
Executes a query and returns the data either in batch or incremental mode.
|
class |
WekaDataGenerator |
Generates artificial data using a Weka data generator.
|
class |
WekaFilterGenerator |
Generates multiple filter setups.
|
class |
WekaForecasterSetup |
Outputs a configured instance of a Weka Forecaster.
|
class |
WekaForecasting |
Uses a serialized model to perform predictions on the data being passed through.
The model can also be obtained from a callable actor, if the model file is pointing to a directory.
|
class |
WekaNewExperiment |
Generates a new ADAMS experiment setup.
|
class |
WekaNewInstances |
Generates an empty dataset, based on the attribute types and names specified.
Nominal attributes are generated with an empty set of labels.
|
class |
WekaPackageManagerAction |
Executes the specified action and forwards the generated output.
|
class |
WekaSelectDataset |
Pops up a file chooser dialog, prompting the user to select one or more datasets.
|
class |
WekaSelectObjects |
Allows the user to select an arbitrary number of Weka objects from the specified class hierarchy using the GenericObjectArray.
|
class |
ZipArrays |
Aligns the corresponding elements of the storage arrays into row-based arrays.
|