Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -1500,17 +1500,17 @@
11 [0, 0]

-- !test --
\N {null:"null"}
1 {0:"string1"}
2 {1:"string2"}
3 {2:"string3"}
4 {3:"string1"}
5 {4:"string2"}
6 {5:"string3"}
7 {6:"string1"}
8 {7:"string2"}
9 {8:"string3"}
10 {9:"string1"}
11 {10:"string2"}
12 {11:"string3"}
\N 1 true null null
1 2 true string1 string1
2 1 false \N string2
3 1 false \N string3
4 1 false \N string1
5 1 false \N string2
6 1 false \N string3
7 1 false \N string1
8 1 false \N string2
9 1 false \N string3
10 1 false \N string1
11 1 false \N string2
12 1 false \N string3

Original file line number Diff line number Diff line change
Expand Up @@ -512,5 +512,14 @@ suite("agg_sync_mv") {
sql "insert into agg_mv_test select * from agg_mv_test;"

sql "set parallel_pipeline_task_num=1"
qt_test "select kbint, map_agg(id, kstr) from agg_mv_test group by kbint order by kbint;"
qt_test """
select kbint, map_size(m), map_contains_key(m, cast(null as int)),
m[cast(null as int)], m[cast(kbint - 1 as int)]
from (
select kbint, map_agg(id, kstr) as m
from agg_mv_test
group by kbint
) t
order by kbint;
"""
}
Loading