@@ -15,6 +15,9 @@ CREATE STREAM [IF NOT EXISTS] stream_name [stream_options] INTO stb_name SUBTABL
stream_options:{
TRIGGER[AT_ONCE|WINDOW_CLOSE|MAX_DELAYtime]
WATERMARKtime
IGNOREEXPIRED[0|1]
DELETE_MARKtime
FILL_HISTORY[0|1]
}
```
...
...
@@ -141,3 +144,30 @@ The data in expired windows is tagged as expired. TDengine stream processing pro
2. Recalculate the data. In this method, all data in the window is reobtained from the database and recalculated. The latest results are then returned.
In both of these methods, configuring the watermark is essential for obtaining accurate results (if expired data is dropped) and avoiding repeated triggers that affect system performance (if expired data is recalculated).
## Supported functions
All scalar functions are available in stream processing.
All System Information Functions are <b>not</b> available for stream processing.
All aggregate and selection functions are available in stream processing, except following functions