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.
scheduler.delay
instead if not used together with delayeachcsv.delimiter: The delimiter for splitting the input (Default: , ).
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'] ] } ) |
CREATE STREAM csv (symbol String, points Double) WRAPPER 'GenericPush' PROTOCOL 'CSV' TRANSPORT 'File' DATAHANDLER 'Tuple' OPTIONS ( 'delimiter' ',', 'textDelimiter' "'", 'readfirstline' 'true', 'delay' '100') |