Files
Lei, HUANG a8924bb95c refactor(udaf): replace uddsketch implementation (#8867)
* refactor(function): replace uddsketch implementation

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* bench(function): compare uddsketch batch ingestion

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* perf(function): avoid copying non-null uddsketch batches

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* fix(function): decode legacy uddsketch states

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* fix(function): harden legacy uddsketch validation

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* format: taplo

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

* test: add compatibility tests for uddsketch functions

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>

---------

Signed-off-by: Lei, HUANG <ratuthomm@gmail.com>
2026-08-14 12:20:04 +00:00

32 lines
633 B
SQL

CREATE TABLE uddsketch_values (
seq_id INT PRIMARY KEY,
val DOUBLE,
ts TIMESTAMP TIME INDEX DEFAULT now()
);
INSERT INTO uddsketch_values (seq_id, val) VALUES
(1, 10.0),
(2, 20.0),
(3, 30.0),
(4, 40.0),
(5, 50.0),
(6, 60.0),
(7, 70.0),
(8, 80.0),
(9, 90.0),
(10, 100.0);
CREATE TABLE uddsketch_states (
state BINARY,
grp INT PRIMARY KEY,
ts TIMESTAMP TIME INDEX DEFAULT now()
);
INSERT INTO uddsketch_states (state, grp)
SELECT uddsketch_state(128, 0.01, val), seq_id / 5 * 5 AS grp
FROM uddsketch_values
GROUP BY grp;
ADMIN FLUSH_TABLE('uddsketch_values');
ADMIN FLUSH_TABLE('uddsketch_states');