mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-10 07:12:54 +00:00
* wip: steppable aggr fn Signed-off-by: discord9 <discord9@163.com> * poc: step aggr query Signed-off-by: discord9 <discord9@163.com> * feat: mvp poc stuff Signed-off-by: discord9 <discord9@163.com> * test: sqlness Signed-off-by: discord9 <discord9@163.com> * chore: import missing Signed-off-by: discord9 <discord9@163.com> * feat: support first/last_value Signed-off-by: discord9 <discord9@163.com> * fix: check also include first/last value Signed-off-by: discord9 <discord9@163.com> * chore: clean up after rebase Signed-off-by: discord9 <discord9@163.com> * feat: optimize yes! Signed-off-by: discord9 <discord9@163.com> * fix: alias qualifled Signed-off-by: discord9 <discord9@163.com> * test: more testcases Signed-off-by: discord9 <discord9@163.com> * chore: qualified column Signed-off-by: discord9 <discord9@163.com> * chore: per review Signed-off-by: discord9 <discord9@163.com> * fix: case when can push down Signed-off-by: discord9 <discord9@163.com> * feat: udd/hll_merge is also the same Signed-off-by: discord9 <discord9@163.com> * fix: udd/hll_merge args Signed-off-by: discord9 <discord9@163.com> * tests: fix sqlness Signed-off-by: discord9 <discord9@163.com> * tests: fix sqlness Signed-off-by: discord9 <discord9@163.com> * fix: udd/hll merge steppable Signed-off-by: discord9 <discord9@163.com> * chore: per review Signed-off-by: discord9 <discord9@163.com> * test: REDACTED Signed-off-by: discord9 <discord9@163.com> * refactor: per review Signed-off-by: discord9 <discord9@163.com> * refactor: more formal transform action Signed-off-by: discord9 <discord9@163.com> * feat: support modify child plan too Signed-off-by: discord9 <discord9@163.com> --------- Signed-off-by: discord9 <discord9@163.com>
49 lines
1.5 KiB
SQL
49 lines
1.5 KiB
SQL
create table t (
|
|
ts timestamp time index,
|
|
val double,
|
|
host string,
|
|
idc string,
|
|
primary key (host, idc),
|
|
)
|
|
partition on columns (host) (
|
|
host < '1024',
|
|
host >= '1024'
|
|
);
|
|
|
|
-- SQLNESS REPLACE (metrics.*) REDACTED
|
|
-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
|
|
-- SQLNESS REPLACE (Hash.*) REDACTED
|
|
-- SQLNESS REPLACE (-+) -
|
|
-- SQLNESS REPLACE (\s\s+) _
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
|
|
-- might write to different partitions
|
|
-- SQLNESS REPLACE "partition_count":\{(.*?)\} "partition_count":REDACTED
|
|
explain analyze
|
|
select sum(val) from t group by host;
|
|
|
|
-- SQLNESS REPLACE (metrics.*) REDACTED
|
|
-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
|
|
-- SQLNESS REPLACE (-+) -
|
|
-- SQLNESS REPLACE (\s\s+) _
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
|
|
-- might write to different partitions
|
|
-- SQLNESS REPLACE "partition_count":\{(.*?)\} "partition_count":REDACTED
|
|
explain analyze
|
|
select sum(val) from t;
|
|
|
|
-- SQLNESS REPLACE (metrics.*) REDACTED
|
|
-- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
|
|
-- SQLNESS REPLACE (Hash.*) REDACTED
|
|
-- SQLNESS REPLACE (-+) -
|
|
-- SQLNESS REPLACE (\s\s+) _
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
|
|
-- might write to different partitions
|
|
-- SQLNESS REPLACE "partition_count":\{(.*?)\} "partition_count":REDACTED
|
|
explain analyze
|
|
select sum(val) from t group by idc;
|
|
|
|
drop table t;
|