mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-07-03 12:30:40 +00:00
* feat(flow): stabilize eval interval scheduling Signed-off-by: discord9 <discord9@163.com> * fix(flow): satisfy eval schedule clippy Signed-off-by: discord9 <discord9@163.com> * test(flow): trim eval schedule coverage Signed-off-by: discord9 <discord9@163.com> * test(flow): cover stable eval scheduling Signed-off-by: discord9 <discord9@163.com> * fix(flow): reserve scheduled runtime hint Signed-off-by: discord9 <discord9@163.com> * test(flow): trim sqlness result eof Signed-off-by: discord9 <discord9@163.com> * fix(flow): harden eval schedule edges Signed-off-by: discord9 <discord9@163.com> * fix(flow): address scheduled flow review Signed-off-by: discord9 <discord9@163.com> * fix(flow): clean scheduled config handling Signed-off-by: discord9 <discord9@163.com> * test(flow): add eval interval compat case Signed-off-by: discord9 <discord9@163.com> * test(flow): cover show create flow in compat Signed-off-by: discord9 <discord9@163.com> * fix(flow): drop scheduled time from flow context Signed-off-by: discord9 <discord9@163.com> * test(flow): assert scheduled now binding Signed-off-by: discord9 <discord9@163.com> --------- Signed-off-by: discord9 <discord9@163.com>
31 lines
644 B
SQL
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);
|