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 interfaceMultiAttemptWithWaitSupporterInterface 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 classDumpFileActor 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 classCopyFileCopies 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.classMoveFileMoves 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.classWaitForFileWaits 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 classScpJobRunnerWraps 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.classSerializingJobRunnerWraps 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.
-