The XLS protocol handler parses and writes Excel-compatible spreadsheets.
Remark: You need to install the XLS feature to use this protocol handler.
scheduler.delay instead if not used together with delayeachinput = ACCESS({source='XLS',
wrapper='GenericPull',
transport='File',
protocol='XLS',
dataHandler='Tuple',
options=[['filename','/home/user/file.xls']],
schema=[['symbol','String'],['points','Double'] ]
})
output = SENDER({sink = 'XLS',
wrapper='GenericPush',
transport='File',
protocol='XLS',
dataHandler='Tuple',
options=[['filename','/home/user/file.xls']],
}, input) |
CREATE STREAM xls (symbol String, points Double)
WRAPPER 'GenericPull'
PROTOCOL 'XLS'
TRANSPORT 'File'
DATAHANDLER 'Tuple'
OPTIONS ( 'filename' '/home/user/file.xls')
CREATE SINK writeout (symbol String, points Double)
WRAPPER 'GenericPush'
PROTOCOL 'XLS'
TRANSPORT 'File'
DATAHANDLER 'Tuple'
OPTIONS ( 'filename' '/home/user/file.xls')
STREAM TO writeout SELECT * FROM input
|