The directory watcher transport handler allows to watch a directory and process modification and creation of files
Options
directortdirectory:
The directory
Example
PQL
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
input = ACCESS({source='Source', wrapper='GenericPush', transport='Directory', protocol='CSV', dataHandler='Tuple', options=[['directory', '/src/odysseus']], schema=[ ['id', 'Double'], ['data', 'String']] }) |
...