The directory watcher transport handler allows to watch a directory and process modification and creation of files
Options
Example
PQL
| Code Block |
|---|
| language | pql |
|---|
| title | Example |
|---|
| linenumbers | true |
|---|
|
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='Directory',
protocol='CSV',
dataHandler='Tuple',
options=[['directory', '/src/odysseus']],
schema=[
['id', 'Double'],
['data', 'String']]
})
|
CQL
| Code Block |
|---|
| language | sql |
|---|
| title | Example |
|---|
| linenumbers | true |
|---|
|
CREATE STREAM source (id Double, data STRING)
WRAPPER 'GenericPush'
PROTOCOL 'CSV'
TRANSPORT 'Directory'
DATAHANDLER 'Tuple'
OPTIONS ( 'filename' '/src/odysseus')
|