The timer transport handler can be used as a periodic data source, which either sends the system time or the time passed since the query started. Can be used with the Command operator.
Options
period:
The period in millisecondstimefromstart
: If set to true, start from 0. Else start from Jan 1th 1970. (Default: false)
Commands
- setperiod: TODO
Example
PQL
Example
input = ACCESS({source='Source', wrapper='GenericPush', transport='Timer', protocol='None', dataHandler='Tuple', options=[['period', '1000'], ['timefromstart', 'true'], schema=[['time', 'Timestamp']] }) or shorter: input = TIMER({PERIOD = 1000, TIMEFROMSTART = true, SOURCE = 'Source'})
CQL
Example
CREATE STREAM source (time Timestamp) WRAPPER 'GenericPush' PROTOCOL 'None' TRANSPORT 'Timer' DATAHANDLER 'Tuple' OPTIONS ( 'period' '1000')