Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

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
languagepql
titleExample
linenumberstrue
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='Directory',
protocol='CSV',
dataHandler='Tuple',
options=[['directory', '/src/odysseus']],
schema=[
['id', 'Double'],
['data', 'String']]
})

...