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. Attribute with the output value is called "time".
period:
The period in millisecondstimefromstart
: If set to true, start from 0 (from Jan 1th 1970) If set to false, uses the current time. (Default: false)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'}) |
CREATE STREAM source (time Timestamp) WRAPPER 'GenericPush' PROTOCOL 'None' TRANSPORT 'Timer' DATAHANDLER 'Tuple' OPTIONS ( 'period' '1000') |