mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-13 16:52:56 +00:00
a9a3e0b121
* feat: use index not col name Signed-off-by: discord9 <discord9@163.com> * fix: use name without qualifier&output schema fix Signed-off-by: discord9 <discord9@163.com> * proto Signed-off-by: discord9 <discord9@163.com> * refactor: resolve column name/index Signed-off-by: discord9 <discord9@163.com> * pcr Signed-off-by: discord9 <discord9@163.com> * chore: update proto Signed-off-by: discord9 <discord9@163.com> * chore: update proto Signed-off-by: discord9 <discord9@163.com> --------- Signed-off-by: discord9 <discord9@163.com>
50 lines
3.9 KiB
Plaintext
50 lines
3.9 KiB
Plaintext
create table count_total (
|
|
ts timestamp time index,
|
|
tag_a string,
|
|
tag_b string,
|
|
val double,
|
|
primary key (tag_a, tag_b),
|
|
);
|
|
|
|
Affected Rows: 0
|
|
|
|
-- if `RangeManipulate` can be encoded/decoded correctly in substrait, the following queries should pass
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE (partitioning.*) REDACTED
|
|
tql explain (0, 100, '1s')
|
|
increase(count_total{
|
|
tag_a="ffa",
|
|
}[1h])[12h:1h];
|
|
|
|
+---------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|
|
| plan_type | plan |
|
|
+---------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|
|
| logical_plan | MergeScan [is_placeholder=false, remote_input=[ |
|
|
| | PromRangeManipulate: req range=[0..0], interval=[300000], eval range=[43200000], time index=[ts], values=["prom_increase(ts_range,val,ts,Int64(3600000))"] |
|
|
| | Filter: prom_increase(ts_range,val,ts,Int64(3600000)) IS NOT NULL |
|
|
| | Projection: count_total.ts, prom_increase(ts_range, val, count_total.ts, Int64(3600000)) AS prom_increase(ts_range,val,ts,Int64(3600000)), count_total.tag_a, count_total.tag_b |
|
|
| | PromRangeManipulate: req range=[-39600000..0], interval=[3600000], eval range=[3600000], time index=[ts], values=["val"] |
|
|
| | PromSeriesNormalize: offset=[0], time index=[ts], filter NaN: [true] |
|
|
| | PromSeriesDivide: tags=["tag_a", "tag_b"] |
|
|
| | Sort: count_total.tag_a ASC NULLS FIRST, count_total.tag_b ASC NULLS FIRST, count_total.ts ASC NULLS FIRST |
|
|
| | Filter: count_total.tag_a = Utf8("ffa") AND count_total.ts >= TimestampMillisecond(-43500000, None) AND count_total.ts <= TimestampMillisecond(300000, None) |
|
|
| | TableScan: count_total |
|
|
| | ]] |
|
|
| physical_plan | CooperativeExec |
|
|
| | MergeScanExec: REDACTED
|
|
| | |
|
|
+---------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|
|
|
|
tql eval (0, 100, '1s')
|
|
increase(count_total{
|
|
tag_a="ffa",
|
|
}[1h])[12h:1h];
|
|
|
|
++
|
|
++
|
|
|
|
drop table count_total;
|
|
|
|
Affected Rows: 0
|
|
|