...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
input = ACCESS({source='XLS', wrapper='GenericPushGenericPull', 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) |
...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
CREATE STREAM xls (symbol String, points Double) WRAPPER 'GenericPushGenericPull' PROTOCOL 'XLS' TRANSPORT 'File' DATAHANDLER 'Tuple' OPTIONS ( 'readfirstlinefilename' 'true', 'delay' '100')/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 |