Page Comparison

...

Code Block

language	sql
linenumbers	true

@info(name = 'query1') 
from inputStream#reorder:kslack(eventTimestamp) 
select eventTimestamp, price, volume 
insert into outputStream;

There are several important variations of the K-slack API of which the details are described below

Table of Contents

Syntax	`<bool> reorder:kslack(<long> timestamp)`
Extension Type	StreamProcessor
Description	This is the most basic version. The events are sorted by the `timestamp` parameter.

...

Syntax	`<bool>` reorder:kslack (<long> timestamp, <long> timeOut, <bool> expireFlag )
Extension Type	StreamProcessor
Description	The fourth argument in the above syntax is a flag that indicates whether the out-of order events that appear after the expiration of the K-slack window should be discarded or not.
Example	`kslack(timestamp, -1l, -1l, true)`

Versions Compared