The Line protocol handler parses simple text lines.

Options

• delay: Delay of reading in milliseconds (default 0). DEPRECATED: use scheduler.delay instead if not used together with delayeach
• nanodelay: Delay of reading in nanoseconds (default 0).
• delayeach: The number of lines between a delay is used (default 0).
• readfirstline: Should the first line of the file be ignored (e.g. because of header information) (default: true)
• debug: If set to true, some additional thinks are available: (default false)
• dumpEachLine: Dumps lines to the console. if set to 1 each line will be dumped
• measureEachLine: Measures the processing time between n elements that are dumped
• lastLine/maxLines: Stop processing after n elements are read

Example

PQL

input = ACCESS({source='Line', wrapper='GenericPush',
transport='File',protocol='Line',
  dataHandler='Tuple',options=[['delay','100']],
  schema=[
    ['symbol','String'],
    ['points','Double'] ]
})

CQL

CREATE STREAM line (symbol String, points Double)   
    WRAPPER 'GenericPush'
    PROTOCOL 'Line'
    TRANSPORT 'File'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'delay' '100')