Uses of Interface
adams.core.MultiAttemptSupporter
-
Packages that use MultiAttemptSupporter Package Description adams.core adams.flow.sink adams.flow.transformer adams.multiprocess -
-
Uses of MultiAttemptSupporter in adams.core
Subinterfaces of MultiAttemptSupporter in adams.core Modifier and Type Interface Description interface
MultiAttemptWithWaitSupporter
Interface for classes that support multiple attempts, but allow a waiting interval in between attempts. -
Uses of MultiAttemptSupporter in adams.flow.sink
Classes in adams.flow.sink that implement MultiAttemptSupporter Modifier and Type Class Description class
DumpFile
Actor that just dumps any input token into a separate line of the specified output file. -
Uses of MultiAttemptSupporter in adams.flow.transformer
Classes in adams.flow.transformer that implement MultiAttemptSupporter Modifier and Type Class Description class
CopyFile
Copies the file received on its input port to the target directory if it matches the provided regular expression.
In case of a directory, the directory gets copied recursively.
If required, you can also provide a new filename (just the name, no path).
The generated target file/directory gets forwarded in the flow.class
MoveFile
Moves a file to a different location (or just renames it).
Source and target can be swapped as well.
Simply forwards the input token if moving was successful.class
WaitForFile
Waits for the file passing through to become available, i.e., not in use by another process. -
Uses of MultiAttemptSupporter in adams.multiprocess
Classes in adams.multiprocess that implement MultiAttemptSupporter Modifier and Type Class Description class
ScpJobRunner
Wraps another jobrunner and serializes it, scp's it to the specified remote file and then waits for the specified import file (containing the serialized, executed jobs) to appear.
Requires a adams.flow.standalone.SSHConnection standalone for defining the SSH connection.class
SerializingJobRunner
Wraps another jobrunner and serializes it to the specified export file and then waits for the specified import file (containing the serialized, executed jobs) to appear.
-