The CSV protocol handler parses delimiter separated text lines.

Important: Each CSV-line must end with a newline! Especially important when not using a file for input but e.g. TCPServer transport handler or AMQP/RabbitMQ transport handler.

Options

Example

PQL

input = ACCESS({
                          source='fridgeVibrationCSV',
                          wrapper='GenericPull',
                          transport='File',
                          protocol='CSV',
                          datahandler='Tuple',
                          options=[
                            ['delimiter',','],
                            ['textDelimiter',"'"],
                            ['readfirstline','true'],
                            ['delay','100'],
                            ['filename', 'path to file']
                          ],
                          schema=[
                            ['description','Double']
                          ]                                                
                        }                                            
                      )

CQL

CREATE STREAM csv (symbol String, points Double)   
    WRAPPER 'GenericPush'
    PROTOCOL 'CSV'
    TRANSPORT 'File'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'delimiter' ',', 'textDelimiter' "'", 'readfirstline' 'true', 'delay' '100')