Versions Compared

Key

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

...

  • filename: The path to the file
  • append: append values to end of file. If set to false (default) the values are overwritten.
  • createdir: When writing to a file, creates the file directory if it doesn't exist. (default false)

Example

PQL

Code Block
themeEclipse
languagejavascript
titleFile Transport Handler
linenumberstrue
input = ACCESS({source='Source',
wrapper='GenericPull',
transport='File',
protocol='CSV',
dataHandler='Tuple',
options=[['filename', '/src/odysseus/input.csv']],
schema=[
['id', 'Double'],
['data', 'String']]
})

output = SENDER({sink='Sink',
wrapper='GenericPush',
transport='File',
protocol='CSV',
dataHandler='Tuple',
options=[['filename', '/src/odysseus/output.csv']]
}, input)

...