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 |