Versions Compared

Key

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

...

  • period: The period in milliseconds
  • timefromstart: Start from Jan 1th 1970. If set to false, start from 0.

Example

PQL

Code Block
languagepql
titleExample
linenumberstrue
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='Timer',
protocol='None',
dataHandler='Tuple',
options=[['period', '1000']],
schema=[['time', 'Timestamp']]
})

or shorter:

input = TIMER({PERIOD = 1000, TIMEFROMSTART = true, SOURCE = 'Source'}) 

CQL

Code Block
languagecql
titleExample
linenumberstrue
CREATE STREAM source (time Timestamp)
    WRAPPER 'GenericPush'
    PROTOCOL 'None'
    TRANSPORT 'Timer'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'period' '1000')