The directory watcher transport handler allows to watch a directory and process modification and creation of files
directory:
The directoryinput = ACCESS({source='Source', wrapper='GenericPush', transport='Directory', protocol='CSV', dataHandler='Tuple', options=[['directory', '/src/odysseus']], schema=[ ['id', 'Double'], ['data', 'String']] }) |
CREATE STREAM source (id Double, data String) WRAPPER 'GenericPush' PROTOCOL 'CSV' TRANSPORT 'Directory' DATAHANDLER 'Tuple' OPTIONS ( 'filename' '/src/odysseus') |