Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
themeEclipse
titleXLS Protocol Handler
linenumberstrue
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
themeEclipse
languagesql
titleXLS Protocol Handler
linenumberstrue
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