You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 4 Next »

The directory watcher transport handler allows to watch a directory and process modification and creation of files

Options

  • directory: The directory

Example

PQL

Example
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='Directory',
protocol='CSV',
dataHandler='Tuple',
options=[['directory', '/src/odysseus']],
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')
  • No labels