...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({ source='CSV', wrapper='GenericPush', transport='File', protocol='CSV', dataHandler datahandler='Tuple', options=[ ['delimiter',','], ['textDelimiter',"'"], ['readfirstline','true'], ['delay','100'] ], schema=[ ['symbol','String'], ['points','Double'] ] } ] } ) ) |
CQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
CREATE STREAM csv (symbol String, points Double) WRAPPER 'GenericPush' PROTOCOL 'CSV' TRANSPORT 'File' DATAHANDLER 'Tuple' OPTIONS ( 'delimiter' ',', 'textDelimiter' "'", 'readfirstline' 'true', 'delay' '100') |