Skip to main content


A sliding time window based on external time. It holds events that arrived during the last window window.time period from the external timestamp, and gets updated on every monotonically increasing timestamp.



Query Parameters

NameDescriptionDefault ValuePossible Data TypesOptionalDynamic
timestampThe Unix timestamp in milliseconds which the window determines as current time and will act upon. The value of this parameter should be monotonically increasing. Max. int is 2^32, or 2147483647.LONGNoYes
window.timeThe sliding time period for which the window should hold events.INT LONG TIMENoNo


CREATE STREAM cseEventStream (symbol string, price float, volume int, eventTime long);
CREATE SINK OutputStream WITH (type='stream', stream='OutputStream') (symbol string, price float);
CREATE WINDOW cseEventWindow (symbol string, price float, volume int, eventTime long) SLIDING_EXTERNAL_TIME(eventTime, 20 sec) OUTPUT expired events;

@info(name = 'query0')
INSERT INTO cseEventWindow
FROM cseEventStream;

@info(name = 'query1')
INSERT expired events INTO OutputStream
SELECT symbol, price
FROM cseEventWindow;

Processing events arrived within the last 20 seconds from the eventTime and output expired events.