...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
input = ACCESS({source='XLS',
wrapper='GenericPush',
transport='File',
protocol='XLS',
dataHandler='Tuple',
options=[['readfirstline'filename','/home/user/file.xls']],
schema=[['symbol','trueString'],['delaypoints','100Double'] ],
})
output schema=[
SENDER({sink = ['symbol','String'],
['points','Double'] ]
}'XLS',
wrapper='GenericPush',
transport='File',
protocol='XLS',
dataHandler='Tuple',
options=[['filename','/home/user/file.xls']],
}, input) |
CQL
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
CREATE STREAM xls (symbol String, points Double) WRAPPER 'GenericPush' PROTOCOL 'XLS' TRANSPORT 'File' DATAHANDLER 'Tuple' OPTIONS ( 'readfirstline' 'true', 'delay' '100') |