The directory watcher transport handler allows to watch a directory and process modification and creation of files
Options
directory:
The directory- filter: The file filter (optional)
Example
PQL
Example
input = ACCESS({source='Source', wrapper='GenericPush', transport='Directory', protocol='CSV', dataHandler='Tuple', options=[['directory', '/src/odysseus'], ['filter', '.txt$']], schema=[ ['id', 'Double'], ['data', 'String']] })
CQL
Example
CREATE STREAM source (id Double, data String) WRAPPER 'GenericPush' PROTOCOL 'CSV' TRANSPORT 'Directory' DATAHANDLER 'Tuple' OPTIONS ( 'filename' '/src/odysseus')