Uses of Interface
adams.core.MultiAttemptWithWaitSupporter

Packages that use MultiAttemptWithWaitSupporter

Package	Description
adams.flow.sink
adams.flow.transformer
adams.multiprocess

Uses of MultiAttemptWithWaitSupporter in adams.flow.sink

Classes in adams.flow.sink that implement MultiAttemptWithWaitSupporter

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 MultiAttemptWithWaitSupporter in adams.flow.transformer

Classes in adams.flow.transformer that implement MultiAttemptWithWaitSupporter

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 MultiAttemptWithWaitSupporter in adams.multiprocess

Classes in adams.multiprocess that implement MultiAttemptWithWaitSupporter

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.