Versions Compared

Key

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

...

Code Block
languagejavascript
themeEclipse
titleCSV Protocol Handler
linenumberstrue
input = ACCESS({
                          source='CSV',
                          wrapper='GenericPush',
                          transport='File',
                          protocol='CSV',
  dataHandler                          datahandler='Tuple',
                          options=[
                            ['delimiter',','],
                            ['textDelimiter',"'"],
                            ['readfirstline','true'],
                            ['delay','100']
                          ],
                          schema=[
                            ['symbol','String'],
                            ['points','Double'] ]
}
                          ]
                        }
                      )
                      )

CQL

Code Block
languagesql
themeEclipse
titleCSV Protocol Handler
linenumberstrue
CREATE STREAM csv (symbol String, points Double)   
    WRAPPER 'GenericPush'
    PROTOCOL 'CSV'
    TRANSPORT 'File'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'delimiter' ',', 'textDelimiter' "'", 'readfirstline' 'true', 'delay' '100')