...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({
source='CSVfridgeVibrationCSV',
wrapper='GenericPushGenericPull',
transport='File',
protocol='CSV',
datahandler='Tuple',
options=[
['delimiter',','],
['textDelimiter',"'"],
['readfirstline','true'],
['delay','100'],
['filename', 'path to file']
],
schema=[
['symboldescription','StringDouble'],
] ['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') |