This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new f7f79267f64 [Chore](case) update agg_sync_mv case (#39837)
f7f79267f64 is described below
commit f7f79267f6401deffdbd2328261ce00a40d8661e
Author: Pxl <[email protected]>
AuthorDate: Mon Aug 26 11:08:04 2024 +0800
[Chore](case) update agg_sync_mv case (#39837)
## Proposed changes
update agg_sync_mv case
---
.../mv/aggregate/agg_sync_mv.groovy | 342 +++++++++++----------
1 file changed, 180 insertions(+), 162 deletions(-)
diff --git
a/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy
b/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy
index 5988d204f6b..ee5135aeaba 100644
--- a/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy
+++ b/regression-test/suites/nereids_syntax_p0/mv/aggregate/agg_sync_mv.groovy
@@ -23,494 +23,512 @@ suite("agg_sync_mv") {
sql """ set enable_stats=false"""
qt_select_any_value """select id, any_value(kint) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, any_value(kint)
from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync1 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync1 as select id,
any_value(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, any_value(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync1)"
}
qt_select_any_value_mv """select id, any_value(kint) from agg_mv_test
group by id order by id;"""
// sum_foreach is not supported in old planner
// qt_select_sum_foreach """select id, sum_foreach(kaint) from agg_mv_test
group by id order by id;"""
- // sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- // createMV("""create materialized view mv_sync as select id,
sum_foreach(kaint) from agg_mv_test group by id order by id;""")
+ // sql """drop materialized view if exists mv_sync2 on agg_mv_test;"""
+ // createMV("""create materialized view mv_sync2 as select id,
sum_foreach(kaint) from agg_mv_test group by id order by id;""")
// explain {
// sql("select id, sum_foreach(kaint) from agg_mv_test group by id
order by id;")
- // contains "(mv_sync)"
+ // contains "(mv_sync2)"
// }
// qt_select_sum_foreach_mv """select id, sum_foreach(kaint) from
agg_mv_test group by id order by id;"""
qt_select_approx_count_distinct """select id, approx_count_distinct(kint)
from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
approx_count_distinct(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync3 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync3 as select id,
approx_count_distinct(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, approx_count_distinct(kint) from agg_mv_test group by
id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync3)"
}
qt_select_approx_count_distinct_mv """select id,
approx_count_distinct(kint) from agg_mv_test group by id order by id;"""
qt_select_collect_set """select id, collect_set(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
collect_set(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync4 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync4 as select id,
collect_set(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, collect_set(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync4)"
}
qt_select_collect_set_mv """select id, collect_set(kint) from agg_mv_test
group by id order by id;"""
qt_select_collect_list """select id, collect_list(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
collect_list(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync5 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync5 as select id,
collect_list(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, collect_list(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync5)"
}
qt_select_collect_list_mv """select id, collect_list(kint) from
agg_mv_test group by id order by id;"""
qt_select_corr """select id, corr(kint, kbint) from agg_mv_test group by
id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, corr(kint,
kbint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync6 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync6 as select id, corr(kint,
kbint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, corr(kint, kbint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync6)"
}
qt_select_corr_mv """select id, corr(kint, kbint) from agg_mv_test group
by id order by id;"""
qt_select_percentile_array """select id, percentile_array(kint,
[0.5,0.55,0.805]) from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
percentile_array(kint, [0.5,0.55,0.805]) from agg_mv_test group by id order by
id;""")
+ sql """drop materialized view if exists mv_sync7 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync7 as select id,
percentile_array(kint, [0.5,0.55,0.805]) from agg_mv_test group by id order by
id;""")
explain {
sql("select id, percentile_array(kint, [0.5,0.55,0.805]) from
agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync7)"
}
qt_select_percentile_array_mv """select id, percentile_array(kint,
[0.5,0.55,0.805]) from agg_mv_test group by id order by id;"""
qt_select_quantile_union """select id,
quantile_union(to_quantile_state(kbint, 2048)) from agg_mv_test group by id
order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
quantile_union(to_quantile_state(kbint, 2048)) from agg_mv_test group by id
order by id;""")
+ sql """drop materialized view if exists mv_sync8 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync8 as select id,
quantile_union(to_quantile_state(kbint, 2048)) from agg_mv_test group by id
order by id;""")
explain {
sql("select id, quantile_union(to_quantile_state(kbint, 2048)) from
agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync8)"
}
qt_select_quantile_union_mv """select id,
quantile_union(to_quantile_state(kbint, 2048)) from agg_mv_test group by id
order by id;"""
qt_select_count_by_enum """select id, count_by_enum(kstr) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
count_by_enum(kstr) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync9 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync9 as select id,
count_by_enum(kstr) from agg_mv_test group by id order by id;""")
explain {
sql("select id, count_by_enum(kstr) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync9)"
}
qt_select_count_by_enum_mv """select id, count_by_enum(kstr) from
agg_mv_test group by id order by id;"""
qt_select_avg_weighted """select id, avg_weighted(ktint, kdbl) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
avg_weighted(ktint, kdbl) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync10 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync10 as select id,
avg_weighted(ktint, kdbl) from agg_mv_test group by id order by id;""")
explain {
sql("select id, avg_weighted(ktint, kdbl) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync10)"
}
qt_select_avg_weighted_mv """select id, avg_weighted(ktint, kdbl) from
agg_mv_test group by id order by id;"""
qt_select_bitmap_intersect """select id,
bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
+ sql """drop materialized view if exists mv_sync11 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync11 as select id,
bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
explain {
sql("select id, bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test
group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync11)"
}
qt_select_bitmap_intersect_mv """select id,
bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;"""
qt_select_bitmap_agg """select id, bitmap_agg(kint) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
bitmap_agg(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync12 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync12 as select id,
bitmap_agg(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, bitmap_agg(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync12)"
}
qt_select_bitmap_agg_mv """select id, bitmap_agg(kint) from agg_mv_test
group by id order by id;"""
qt_select_bitmap_union """select id, bitmap_union(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
bitmap_union(bitmap_hash(kbint)) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync13 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync13 as select id,
bitmap_union(bitmap_hash(kbint)) from agg_mv_test group by id order by id;""")
explain {
sql("select id, bitmap_union(bitmap_hash(kbint)) from agg_mv_test
group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync13)"
}
qt_select_bitmap_union_mv """select id, bitmap_union(bitmap_hash(kbint))
from agg_mv_test group by id order by id;"""
qt_select_bitmap_union_count """select id,
bitmap_union_count(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
bitmap_union_count(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
+ sql """drop materialized view if exists mv_sync14 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync14 as select id,
bitmap_union_count(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
explain {
sql("select id, bitmap_union_count(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync14)"
}
qt_select_bitmap_union_count_mv """select id,
bitmap_union_count(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;"""
qt_select_bitmap_union_int """select id, bitmap_union_int(kint) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
bitmap_union_int(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync15 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync15 as select id,
bitmap_union_int(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, bitmap_union_int(kint) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync15)"
}
qt_select_bitmap_union_int_mv """select id, bitmap_union_int(kint) from
agg_mv_test group by id order by id;"""
qt_select_group_array_intersect """select id, group_array_intersect(kaint)
from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
group_array_intersect(kaint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync16 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync16 as select id,
group_array_intersect(kaint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, group_array_intersect(kaint) from agg_mv_test group by
id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync16)"
}
qt_select_group_array_intersect_mv """select id,
group_array_intersect(kaint) from agg_mv_test group by id order by id;"""
qt_select_group_bit_and """select id, group_bit_and(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
group_bit_and(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync17 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync17 as select id,
group_bit_and(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, group_bit_and(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync17)"
}
qt_select_group_bit_and_mv """select id, group_bit_and(kint) from
agg_mv_test group by id order by id;"""
qt_select_group_bit_or """select id, group_bit_or(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
group_bit_or(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync18 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync18 as select id,
group_bit_or(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, group_bit_or(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync18)"
}
qt_select_group_bit_or_mv """select id, group_bit_or(kint) from
agg_mv_test group by id order by id;"""
qt_select_group_bit_xor """select id, group_bit_xor(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
group_bit_xor(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync19 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync19 as select id,
group_bit_xor(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, group_bit_xor(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync19)"
}
qt_select_group_bit_xor_mv """select id, group_bit_xor(kint) from
agg_mv_test group by id order by id;"""
qt_select_group_bitmap_xor """select id,
group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
+ sql """drop materialized view if exists mv_sync20 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync20 as select id,
group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
explain {
sql("select id, group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test
group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync20)"
}
qt_select_group_bitmap_xor_mv """select id,
group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;"""
qt_select_hll_union_agg """select id, hll_union_agg(hll_hash(kbint)) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
hll_union_agg(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync21 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync21 as select id,
hll_union_agg(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
explain {
sql("select id, hll_union_agg(hll_hash(kbint)) from agg_mv_test group
by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync21)"
}
qt_select_hll_union_agg_mv """select id, hll_union_agg(hll_hash(kbint))
from agg_mv_test group by id order by id;"""
qt_select_hll_union """select id, hll_union(hll_hash(kbint)) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
hll_union(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync22 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync22 as select id,
hll_union(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
explain {
sql("select id, hll_union(hll_hash(kbint)) from agg_mv_test group by
id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync22)"
}
qt_select_hll_union_mv """select id, hll_union(hll_hash(kbint)) from
agg_mv_test group by id order by id;"""
qt_select_intersect_count """select id,
intersect_count(bitmap_hash(kbint), kint, 3, 4) from agg_mv_test group by id
order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
intersect_count(bitmap_hash(kbint), kint, 3, 4) from agg_mv_test group by id
order by id;""")
+ sql """drop materialized view if exists mv_sync23 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync23 as select id,
intersect_count(bitmap_hash(kbint), kint, 3, 4) from agg_mv_test group by id
order by id;""")
explain {
sql("select id, intersect_count(bitmap_hash(kbint), kint, 3, 4) from
agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync23)"
}
qt_select_intersect_count_mv """select id,
intersect_count(bitmap_hash(kbint), kint, 3, 4) from agg_mv_test group by id
order by id;"""
qt_select_group_concat """select id, group_concat(cast(abs(kint) as
varchar)) from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
group_concat(cast(abs(kint) as varchar)) from agg_mv_test group by id order by
id;""")
+ sql """drop materialized view if exists mv_sync24 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync24 as select id,
group_concat(cast(abs(kint) as varchar)) from agg_mv_test group by id order by
id;""")
explain {
sql("select id, group_concat(cast(abs(kint) as varchar)) from
agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync24)"
}
qt_select_group_concat_mv """select id, group_concat(cast(abs(kint) as
varchar)) from agg_mv_test group by id order by id;"""
qt_select_multi_distinct_group_concat """select id,
multi_distinct_group_concat(cast(abs(kint) as varchar)) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
multi_distinct_group_concat(cast(abs(kint) as varchar)) from agg_mv_test group
by id order by id;""")
+ sql """drop materialized view if exists mv_sync25 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync25 as select id,
multi_distinct_group_concat(cast(abs(kint) as varchar)) from agg_mv_test group
by id order by id;""")
explain {
sql("select id, multi_distinct_group_concat(cast(abs(kint) as
varchar)) from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync25)"
}
qt_select_multi_distinct_group_concat_mv """select id,
multi_distinct_group_concat(cast(abs(kint) as varchar)) from agg_mv_test group
by id order by id;"""
qt_select_multi_distinct_sum0 """select id, multi_distinct_sum0(kint) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
multi_distinct_sum0(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync26 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync26 as select id,
multi_distinct_sum0(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, multi_distinct_sum0(kint) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync26)"
}
qt_select_multi_distinct_sum0_mv """select id, multi_distinct_sum0(kint)
from agg_mv_test group by id order by id;"""
qt_select_multi_distinct_sum """select id, multi_distinct_sum(kint) from
agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
multi_distinct_sum(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync27 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync27 as select id,
multi_distinct_sum(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, multi_distinct_sum(kint) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync27)"
}
qt_select_multi_distinct_sum_mv """select id, multi_distinct_sum(kint)
from agg_mv_test group by id order by id;"""
qt_select_histogram """select id, histogram(kint) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, histogram(kint)
from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync28 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync28 as select id,
histogram(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, histogram(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync28)"
}
qt_select_histogram_mv """select id, histogram(kint) from agg_mv_test
group by id order by id;"""
qt_select_max_by """select id, max_by(kint, kint) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, max_by(kint,
kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync29 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync29 as select id, max_by(kint,
kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, max_by(kint, kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync29)"
}
qt_select_max_by_mv """select id, max_by(kint, kint) from agg_mv_test
group by id order by id;"""
qt_select_min_by """select id, min_by(kint, kint) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, min_by(kint,
kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync30 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync30 as select id, min_by(kint,
kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, min_by(kint, kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync30)"
}
qt_select_min_by_mv """select id, min_by(kint, kint) from agg_mv_test
group by id order by id;"""
qt_select_multi_distinct_count """select id, multi_distinct_count(kint)
from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
multi_distinct_count(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync31 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync31 as select id,
multi_distinct_count(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, multi_distinct_count(kint) from agg_mv_test group by
id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync31)"
}
qt_select_multi_distinct_count_mv """select id, multi_distinct_count(kint)
from agg_mv_test group by id order by id;"""
qt_select_ndv """select id, ndv(kint) from agg_mv_test group by id order
by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, ndv(kint) from
agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync32 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync32 as select id, ndv(kint)
from agg_mv_test group by id order by id;""")
explain {
sql("select id, ndv(kint) from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync32)"
}
qt_select_ndv_mv """select id, ndv(kint) from agg_mv_test group by id
order by id;"""
qt_select_covar """select id, covar(kint, kint) from agg_mv_test group by
id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, covar(kint,
kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync33 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync33 as select id, covar(kint,
kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, covar(kint, kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync33)"
}
qt_select_covar_mv """select id, covar(kint, kint) from agg_mv_test group
by id order by id;"""
qt_select_covar_samp """select id, covar_samp(kint, kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
covar_samp(kint, kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync34 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync34 as select id,
covar_samp(kint, kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, covar_samp(kint, kint) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync34)"
}
qt_select_covar_samp_mv """select id, covar_samp(kint, kint) from
agg_mv_test group by id order by id;"""
qt_select_percentile """select id, percentile(kbint, 0.6) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
percentile(kbint, 0.6) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync35 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync35 as select id,
percentile(kbint, 0.6) from agg_mv_test group by id order by id;""")
explain {
sql("select id, percentile(kbint, 0.6) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync35)"
}
qt_select_percentile_mv """select id, percentile(kbint, 0.6) from
agg_mv_test group by id order by id;"""
qt_select_percentile_approx """select id, percentile_approx(kbint, 0.6)
from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
percentile_approx(kbint, 0.6) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync36 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync36 as select id,
percentile_approx(kbint, 0.6) from agg_mv_test group by id order by id;""")
explain {
sql("select id, percentile_approx(kbint, 0.6) from agg_mv_test group
by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync36)"
}
qt_select_percentile_approx_mv """select id, percentile_approx(kbint, 0.6)
from agg_mv_test group by id order by id;"""
// percentile_approx_weighted is not supported in old planner
// qt_select_percentile_approx_weighted """select id,
percentile_approx_weighted(kint, kbint, 0.6) from agg_mv_test group by id order
by id;"""
- // sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- // createMV("""create materialized view mv_sync as select id,
percentile_approx_weighted(kint, kbint, 0.6) from agg_mv_test group by id order
by id;""")
+ // sql """drop materialized view if exists mv_sync37 on agg_mv_test;"""
+ // createMV("""create materialized view mv_sync37 as select id,
percentile_approx_weighted(kint, kbint, 0.6) from agg_mv_test group by id order
by id;""")
// explain {
// sql("select id, percentile_approx_weighted(kint, kbint, 0.6) from
agg_mv_test group by id order by id;")
- // contains "(mv_sync)"
+ // contains "(mv_sync37)"
// }
// qt_select_percentile_approx_weighted_mv """select id,
percentile_approx_weighted(kint, kbint, 0.6) from agg_mv_test group by id order
by id;"""
qt_select_sequence_count """select id, sequence_count('(?1)(?2)', kdtv2,
kint = 1, kint = 2) from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
sequence_count('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
+ sql """drop materialized view if exists mv_sync38 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync38 as select id,
sequence_count('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
explain {
sql("select id, sequence_count('(?1)(?2)', kdtv2, kint = 1, kint = 2)
from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync38)"
}
qt_select_sequence_count_mv """select id, sequence_count('(?1)(?2)',
kdtv2, kint = 1, kint = 2) from agg_mv_test group by id order by id;"""
qt_select_sequence_match """select id, sequence_match('(?1)(?2)', kdtv2,
kint = 1, kint = 2) from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
sequence_match('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
+ sql """drop materialized view if exists mv_sync39 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync39 as select id,
sequence_match('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
explain {
sql("select id, sequence_match('(?1)(?2)', kdtv2, kint = 1, kint = 2)
from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync39)"
}
qt_select_sequence_match_mv """select id, sequence_match('(?1)(?2)',
kdtv2, kint = 1, kint = 2) from agg_mv_test group by id order by id;"""
qt_select_stddev """select id, stddev(kint) from agg_mv_test group by id
order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, stddev(kint)
from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync40 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync40 as select id, stddev(kint)
from agg_mv_test group by id order by id;""")
explain {
sql("select id, stddev(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync40)"
}
qt_select_stddev_mv """select id, stddev(kint) from agg_mv_test group by
id order by id;"""
qt_select_stddev_pop """select id, stddev_pop(kint) from agg_mv_test group
by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
stddev_pop(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync41 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync41 as select id,
stddev_pop(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, stddev_pop(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync41)"
}
qt_select_stddev_pop_mv """select id, stddev_pop(kint) from agg_mv_test
group by id order by id;"""
qt_select_stddev_samp """select id, stddev_samp(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
stddev_samp(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync42 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync42 as select id,
stddev_samp(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, stddev_samp(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync42)"
}
qt_select_stddev_samp_mv """select id, stddev_samp(kint) from agg_mv_test
group by id order by id;"""
qt_select_sum0 """select id, sum0(kint) from agg_mv_test group by id order
by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, sum0(kint) from
agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync43 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync43 as select id, sum0(kint)
from agg_mv_test group by id order by id;""")
explain {
sql("select id, sum0(kint) from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync43)"
}
qt_select_sum0_mv """select id, sum0(kint) from agg_mv_test group by id
order by id;"""
qt_select_topn """select id, topn(kvchrs1, 3) from agg_mv_test group by id
order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, topn(kvchrs1,
3) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync44 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync44 as select id, topn(kvchrs1,
3) from agg_mv_test group by id order by id;""")
explain {
sql("select id, topn(kvchrs1, 3) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync44)"
}
qt_select_topn_mv """select id, topn(kvchrs1, 3) from agg_mv_test group by
id order by id;"""
qt_select_topn_array """select id, topn_array(kvchrs1, 3) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
topn_array(kvchrs1, 3) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync45 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync45 as select id,
topn_array(kvchrs1, 3) from agg_mv_test group by id order by id;""")
explain {
sql("select id, topn_array(kvchrs1, 3) from agg_mv_test group by id
order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync45)"
}
qt_select_topn_array_mv """select id, topn_array(kvchrs1, 3) from
agg_mv_test group by id order by id;"""
qt_select_topn_weighted """select id, topn_weighted(kvchrs1, ktint, 3)
from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
topn_weighted(kvchrs1, ktint, 3) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync46 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync46 as select id,
topn_weighted(kvchrs1, ktint, 3) from agg_mv_test group by id order by id;""")
explain {
sql("select id, topn_weighted(kvchrs1, ktint, 3) from agg_mv_test
group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync46)"
}
qt_select_topn_weighted_mv """select id, topn_weighted(kvchrs1, ktint, 3)
from agg_mv_test group by id order by id;"""
qt_select_variance """select id, variance(kint) from agg_mv_test group by
id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, variance(kint)
from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync47 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync47 as select id,
variance(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, variance(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync47)"
}
qt_select_variance_mv """select id, variance(kint) from agg_mv_test group
by id order by id;"""
qt_select_var_pop """select id, var_pop(kint) from agg_mv_test group by id
order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, var_pop(kint)
from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync48 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync48 as select id, var_pop(kint)
from agg_mv_test group by id order by id;""")
explain {
sql("select id, var_pop(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync47)"
}
qt_select_var_pop_mv """select id, var_pop(kint) from agg_mv_test group by
id order by id;"""
qt_select_variance_samp """select id, variance_samp(kint) from agg_mv_test
group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
variance_samp(kint) from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync49 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync49 as select id,
variance_samp(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, variance_samp(kint) from agg_mv_test group by id order
by id;")
- contains "(mv_sync)"
+ contains "(mv_sync49)"
}
qt_select_variance_samp_mv """select id, variance_samp(kint) from
agg_mv_test group by id order by id;"""
qt_select_var_samp """select id, var_samp(kint) from agg_mv_test group by
id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, var_samp(kint)
from agg_mv_test group by id order by id;""")
+ sql """drop materialized view if exists mv_sync50 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync50 as select id,
var_samp(kint) from agg_mv_test group by id order by id;""")
explain {
sql("select id, var_samp(kint) from agg_mv_test group by id order by
id;")
- contains "(mv_sync)"
+ contains "(mv_sync50)"
}
qt_select_var_samp_mv """select id, var_samp(kint) from agg_mv_test group
by id order by id;"""
qt_select_window_funnel """select id, window_funnel(3600 * 3, 'default',
kdtm, kint = 1, kint = 2) from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id,
window_funnel(3600 * 3, 'default', kdtm, kint = 1, kint = 2) from agg_mv_test
group by id order by id;""")
+ sql """drop materialized view if exists mv_sync51 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync51 as select id,
window_funnel(3600 * 3, 'default', kdtm, kint = 1, kint = 2) from agg_mv_test
group by id order by id;""")
explain {
sql("select id, window_funnel(3600 * 3, 'default', kdtm, kint = 1,
kint = 2) from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync51)"
}
qt_select_window_funnel_mv """select id, window_funnel(3600 * 3,
'default', kdtm, kint = 1, kint = 2) from agg_mv_test group by id order by
id;"""
// map_agg is not supported yet
// qt_select_map_agg """select id, map_agg(kint, kstr) from agg_mv_test
group by id order by id;"""
- // sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- // createMV("""create materialized view mv_sync as select id,
map_agg(kint, kstr) from agg_mv_test group by id order by id;""")
+ // sql """drop materialized view if exists mv_sync52 on agg_mv_test;"""
+ // createMV("""create materialized view mv_sync52 as select id,
map_agg(kint, kstr) from agg_mv_test group by id order by id;""")
// explain {
// sql("select id, map_agg(kint, kstr) from agg_mv_test group by id
order by id;")
- // contains "(mv_sync)"
+ // contains "(mv_sync52)"
// }
// qt_select_map_agg_mv """select id, map_agg(kint, kstr) from agg_mv_test
group by id order by id;"""
// array_agg is not supported yet
// qt_select_array_agg """select id, array_agg(kstr) from agg_mv_test
group by id order by id;"""
- // sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- // createMV("""create materialized view mv_sync as select id,
array_agg(kstr) from agg_mv_test group by id order by id;""")
+ // sql """drop materialized view if exists mv_sync53 on agg_mv_test;"""
+ // createMV("""create materialized view mv_sync53 as select id,
array_agg(kstr) from agg_mv_test group by id order by id;""")
// explain {
// sql("select id, array_agg(kstr) from agg_mv_test group by id order
by id;")
- // contains "(mv_sync)"
+ // contains "(mv_sync53)"
// }
// qt_select_array_agg_mv """select id, array_agg(kstr) from agg_mv_test
group by id order by id;"""
qt_select_retention """select id, retention(kdtm = '2012-03-11', kdtm =
'2012-03-12') from agg_mv_test group by id order by id;"""
- sql """drop materialized view if exists mv_sync on agg_mv_test;"""
- createMV("""create materialized view mv_sync as select id, retention(kdtm
= '2012-03-11', kdtm = '2012-03-12') from agg_mv_test group by id order by
id;""")
+ sql """drop materialized view if exists mv_sync54 on agg_mv_test;"""
+ createMV("""create materialized view mv_sync54 as select id,
retention(kdtm = '2012-03-11', kdtm = '2012-03-12') from agg_mv_test group by
id order by id;""")
explain {
sql("select id, retention(kdtm = '2012-03-11', kdtm = '2012-03-12')
from agg_mv_test group by id order by id;")
- contains "(mv_sync)"
+ contains "(mv_sync54)"
}
qt_select_retention_mv """select id, retention(kdtm = '2012-03-11', kdtm =
'2012-03-12') from agg_mv_test group by id order by id;"""
+
+ streamLoad {
+ table "agg_mv_test"
+ db "regression_test_nereids_syntax_p0_mv"
+ set 'column_separator', ';'
+ set 'columns', '''
+ id, kbool, ktint, ksint, kint, kbint, klint, kfloat, kdbl,
kdcmls1, kdcmls2, kdcmls3,
+ kdcmlv3s1, kdcmlv3s2, kdcmlv3s3, kchrs1, kchrs2, kchrs3, kvchrs1,
kvchrs2, kvchrs3, kstr,
+ kdt, kdtv2, kdtm, kdtmv2s1, kdtmv2s2, kdtmv2s3, kabool, katint,
kasint, kaint,
+ kabint, kalint, kafloat, kadbl, kadt, kadtm, kadtv2, kadtmv2,
kachr, kavchr, kastr, kadcml,
+ st_point_str, st_point_vc, x_lng, x_lat, y_lng, y_lat, z_lng,
z_lat, radius, linestring_wkt, polygon_wkt,
+ km_bool_tint, km_tint_tint, km_sint_tint, km_int_tint,
km_bint_tint, km_lint_tint, km_float_tint,
+ km_dbl_tint, km_dcml_tint, km_chr_tint, km_vchr_tint, km_str_tint,
km_date_tint, km_dtm_tint,
+ km_tint_bool, km_int_int, km_tint_sint, km_tint_int, km_tint_bint,
km_tint_lint, km_tint_float,
+ km_tint_dbl, km_tint_dcml, km_tint_chr, km_tint_vchr, km_tint_str,
km_tint_date, km_tint_dtm, kjson, kstruct
+ '''
+ file "../agg_mv_test.dat"
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
