Files
greptimedb/tests/compatibility/cases/flow_eval_interval/setup.sql
Yingwen 4071cb56ae feat(flow): stabilize eval interval scheduling (#8360) (#8378)
* feat(flow): stabilize eval interval scheduling



* fix(flow): satisfy eval schedule clippy



* test(flow): trim eval schedule coverage



* test(flow): cover stable eval scheduling



* fix(flow): reserve scheduled runtime hint



* test(flow): trim sqlness result eof



* fix(flow): harden eval schedule edges



* fix(flow): address scheduled flow review



* fix(flow): clean scheduled config handling



* test(flow): add eval interval compat case



* test(flow): cover show create flow in compat



* fix(flow): drop scheduled time from flow context



* test(flow): assert scheduled now binding



---------

Signed-off-by: discord9 <discord9@163.com>
Signed-off-by: evenyag <realevenyag@gmail.com>
Co-authored-by: discord9 <discord9@163.com>
2026-06-29 21:27:22 +08:00

31 lines
644 B
SQL

CREATE TABLE compat_sql_input (
ts TIMESTAMP(3) TIME INDEX,
series STRING,
v DOUBLE,
PRIMARY KEY(series)
);
CREATE FLOW compat_sql_eval_flow
SINK TO compat_sql_eval_sink
EVAL INTERVAL '1s'
AS
SELECT
date_trunc('second', now()) AS ts,
count(v) AS value_count
FROM compat_sql_input
GROUP BY date_trunc('second', now());
CREATE TABLE compat_tql_input (
ts TIMESTAMP(3) TIME INDEX,
host STRING,
idc STRING,
val DOUBLE,
PRIMARY KEY(host, idc)
);
CREATE FLOW compat_tql_eval_flow
SINK TO compat_tql_eval_sink
EVAL INTERVAL '1s'
AS
TQL EVAL (now() - '1m'::interval, now(), '5s') count_values("status_code", compat_tql_input);