This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 8763934eb29 branch-3.1: [fix](test) Fix mv case wrongly and fix mv
rewrite fail when sync mv used all agg table group by field #55878 (#56174)
8763934eb29 is described below
commit 8763934eb29472dd387081baf58a11e53673091c
Author: seawinde <[email protected]>
AuthorDate: Thu Sep 25 17:15:24 2025 +0800
branch-3.1: [fix](test) Fix mv case wrongly and fix mv rewrite fail when
sync mv used all agg table group by field #55878 (#56174)
picked from #55878
---
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 4 +-
.../suites/mv_p0/agg_table_mv/agg_table_mv.groovy | 81 ++++++++++++++++
.../mv/aggregate/agg_sync_mv.groovy | 106 ++++++++++-----------
.../mv/aggregate/agg_sync_mv.groovy | 102 ++++++++++----------
4 files changed, 188 insertions(+), 105 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVPlanUtil.java
b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVPlanUtil.java
index 24379291dfa..15ef46140a4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVPlanUtil.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVPlanUtil.java
@@ -100,7 +100,9 @@ public class MTMVPlanUtil {
ctx.getSessionVariable().allowModifyMaterializedViewData = true;
// Disable add default limit rule to avoid refresh data wrong
ctx.getSessionVariable().setDisableNereidsRules(
- String.join(",",
ImmutableSet.of(RuleType.ADD_DEFAULT_LIMIT.name())));
+ String.join(",", ImmutableSet.of(
+ RuleType.ADD_DEFAULT_LIMIT.name(),
+ RuleType.ELIMINATE_GROUP_BY.name())));
ctx.setStartTime();
if (parentContext != null) {
ctx.changeDefaultCatalog(parentContext.getDefaultCatalog());
diff --git a/regression-test/suites/mv_p0/agg_table_mv/agg_table_mv.groovy
b/regression-test/suites/mv_p0/agg_table_mv/agg_table_mv.groovy
new file mode 100644
index 00000000000..5afe1d0374b
--- /dev/null
+++ b/regression-test/suites/mv_p0/agg_table_mv/agg_table_mv.groovy
@@ -0,0 +1,81 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+import org.codehaus.groovy.runtime.IOGroovyMethods
+
+suite ("agg_table_mv") {
+
+ String db = context.config.getDbNameByFile(context.file)
+ sql "use ${db}"
+
+ sql """set enable_nereids_planner=true;"""
+ sql """ DROP TABLE IF EXISTS orders_agg; """
+
+ sql """
+ CREATE TABLE `orders_agg` (
+ `o_orderkey` BIGINT not NULL,
+ `o_custkey` INT not NULL,
+ `o_orderdate` DATE not null,
+ `o_orderstatus` VARCHAR(1) replace,
+ `o_totalprice` DECIMAL(15, 2) sum,
+ `o_orderpriority` VARCHAR(15) replace,
+ `o_clerk` VARCHAR(15) replace,
+ `o_shippriority` INT sum,
+ `o_comment` VARCHAR(79) replace
+ ) ENGINE=OLAP
+ aggregate KEY(`o_orderkey`, `o_custkey`, `o_orderdate`)
+ COMMENT 'OLAP'
+ auto partition by range (date_trunc(`o_orderdate`, 'day')) ()
+ DISTRIBUTED BY HASH(`o_orderkey`) BUCKETS 96
+ PROPERTIES (
+ "replication_allocation" = "tag.location.default: 1"
+ );
+ """
+
+ sql """
+ insert into orders_agg values
+ (2, 1, '2023-10-17', 'k', 99.5, 'a', 'b', 1, 'yy'),
+ (1, 2, '2023-10-17', 'o', 109.2, 'c','d',2, 'mm'),
+ (3, 3, '2023-10-19', null, 99.5, 'a', 'b', 1, 'yy'),
+ (1, 2, '2023-10-20', 'o', null, 'a', 'b', 1, 'yy'),
+ (2, 3, '2023-10-21', 'k', 109.2, null,'d',2, 'mm'),
+ (3, 1, '2023-10-22', 'k', 99.5, 'a', null, 1, 'yy'),
+ (1, 3, '2023-10-19', 'o', 99.5, 'a', 'b', null, 'yy'),
+ (2, 1, '2023-10-18', 'o', 109.2, 'c','d',2, null),
+ (3, 2, '2023-10-17', 'k', 99.5, 'a', 'b', 1, 'yy'),
+ (4, 5, '2023-10-19', 'k', 99.5, 'a', 'b', 1, 'yy');
+ """
+
+ create_sync_mv(db, "orders_agg", "agg_mv_name_3", """
+ select o_orderdatE as a_o_orderdatE, o_custkey as a_o_custkey,
o_orderkey as a_o_orderkey,
+ sum(o_totalprice) as sum_total
+ from orders_agg
+ group by
+ o_orderdatE,
+ o_custkey,
+ o_orderkey;
+ """)
+
+ mv_rewrite_success("""
+ select o_custkey, o_orderkey,
+ sum(o_totalprice) as sum_total
+ from orders_agg
+ group by
+ o_custkey,
+ o_orderkey
+ """, "agg_mv_name_3")
+}
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 ed4debebbc6..8e8f139efec 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
@@ -24,7 +24,7 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync1 as select id as a1,
any_value(kint) as a2 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, any_value(kint) from agg_mv_test group by
id order by id;", "mv_sync1")
qt_select_any_value_mv """select id, any_value(kint) from agg_mv_test
group by id order by id;"""
@@ -40,206 +40,206 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync3 as select id as a3,
approx_count_distinct(kint) as a4 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, approx_count_distinct(kint) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync4 as select id as a5,
collect_set(kint) as a6 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, collect_set(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync5 as select id as a7,
collect_list(kint) as a8 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, collect_list(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync6 as select id as b1,
corr(kint, kbint) as b2 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, corr(kint, kbint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync7 as select id as b3,
percentile_array(kint, [0.5,0.55,0.805]) as b4 from agg_mv_test group by id
order by id;""")
mv_rewrite_success("select id, percentile_array(kint, [0.5,0.55,0.805])
from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync8 as select id as b5,
quantile_union(to_quantile_state(kbint, 2048)) as b6 from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, quantile_union(to_quantile_state(kbint,
2048)) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync9 as select id as b7,
count_by_enum(kstr) as b8 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, count_by_enum(kstr) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync10 as select id as c1,
avg_weighted(ktint, kdbl) as c2 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, avg_weighted(ktint, kdbl) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync11 as select id as c3,
bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, bitmap_intersect(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync12 as select id as c4,
bitmap_agg(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, bitmap_agg(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync13 as select id as c5,
bitmap_union(bitmap_hash(kbint)) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, bitmap_union(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
- mv_rewrite_success("select id, bitmap_union_count(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "mv_sync14")
+ createMV("""create materialized view mv_sync14 as select id as c6,
bitmap_union_count(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
+ mv_rewrite_any_success("select id, bitmap_union_count(bitmap_hash(kbint))
from agg_mv_test group by id order by id;", ["mv_sync14", "mv_sync13"])
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_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;""")
+ createMV("""create materialized view mv_sync15 as select id as c7,
bitmap_union_int(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, bitmap_union_int(kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync16 as select id as c8,
group_array_intersect(kaint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_array_intersect(kaint) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync17 as select id as d1,
group_bit_and(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_bit_and(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync18 as select id as d2,
group_bit_or(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_bit_or(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync19 as select id as d3,
group_bit_xor(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_bit_xor(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync20 as select id as d4,
group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, group_bitmap_xor(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync21 as select id as d5,
hll_union_agg(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, hll_union_agg(hll_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync22 as select id as d6,
hll_union(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, hll_union(hll_hash(kbint)) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync23 as select id as d7,
intersect_count(bitmap_hash(kbint), kint, 3, 4) from agg_mv_test group by id
order by id;""")
mv_rewrite_success("select id, intersect_count(bitmap_hash(kbint), kint,
3, 4) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync24 as select id as d8,
group_concat(cast(abs(kint) as varchar)) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, group_concat(cast(abs(kint) as varchar))
from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync25 as select id as e2,
multi_distinct_group_concat(cast(abs(kint) as varchar)) from agg_mv_test group
by id order by id;""")
mv_rewrite_success("select id, multi_distinct_group_concat(cast(abs(kint)
as varchar)) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync26 as select id as e3,
multi_distinct_sum0(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, multi_distinct_sum0(kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync27 as select id as e4,
multi_distinct_sum(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, multi_distinct_sum(kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync28 as select id as e5,
histogram(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, histogram(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync29 as select id as e6,
max_by(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, max_by(kint, kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync30 as select id as e7,
min_by(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, min_by(kint, kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync31 as select id as e8,
multi_distinct_count(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, multi_distinct_count(kint) from agg_mv_test
group by id order by id;", "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_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;""")
- mv_rewrite_success("select id, ndv(kint) from agg_mv_test group by id
order by id;", "mv_sync32")
+ createMV("""create materialized view mv_sync32 as select id as f1,
ndv(kint) from agg_mv_test group by id order by id;""")
+ mv_rewrite_any_success("select id, ndv(kint) from agg_mv_test group by id
order by id;", ["mv_sync32", "mv_sync3"])
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_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;""")
+ createMV("""create materialized view mv_sync33 as select id as f2,
covar(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, covar(kint, kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync34 as select id as f3,
covar_samp(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, covar_samp(kint, kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync35 as select id as f4,
percentile(kbint, 0.6) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, percentile(kbint, 0.6) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync36 as select id as f5,
percentile_approx(kbint, 0.6) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, percentile_approx(kbint, 0.6) from
agg_mv_test group by id order by id;", "mv_sync36")
qt_select_percentile_approx_mv """select id, percentile_approx(kbint, 0.6)
from agg_mv_test group by id order by id;"""
@@ -255,85 +255,85 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync38 as select id as f6,
sequence_count('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, sequence_count('(?1)(?2)', kdtv2, kint = 1,
kint = 2) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync39 as select id as f7,
sequence_match('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, sequence_match('(?1)(?2)', kdtv2, kint = 1,
kint = 2) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync40 as select id as f8,
stddev(kint) as xx1 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, stddev(kint) from agg_mv_test group by id
order by id;", "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_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;""")
- mv_rewrite_success("select id, stddev_pop(kint) from agg_mv_test group by
id order by id;", "mv_sync41")
+ createMV("""create materialized view mv_sync41 as select id as g1,
stddev_pop(kint) as yy1 from agg_mv_test group by id order by id;""")
+ mv_rewrite_any_success("select id, stddev_pop(kint) from agg_mv_test group
by id order by id;", ["mv_sync40", "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_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;""")
+ createMV("""create materialized view mv_sync42 as select id as g2,
stddev_samp(kint) as xx3 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, stddev_samp(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync43 as select id as g3,
sum0(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, sum0(kint) from agg_mv_test group by id
order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync44 as select id as g4,
topn(kvchrs1, 3) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, topn(kvchrs1, 3) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync45 as select id as g5,
topn_array(kvchrs1, 3) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, topn_array(kvchrs1, 3) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync46 as select id as g6,
topn_weighted(kvchrs1, ktint, 3) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, topn_weighted(kvchrs1, ktint, 3) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync47 as select id as g7,
variance(kint) as xx7 from agg_mv_test group by id order by id;""")
mv_rewrite_any_success("select id, variance(kint) from agg_mv_test group
by id order by id;", ["mv_sync47", "mv_sync48"])
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_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;""")
+ createMV("""create materialized view mv_sync48 as select id as g8,
var_pop(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_any_success("select id, var_pop(kint) from agg_mv_test group by
id order by id;",["mv_sync47", "mv_sync48"])
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_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;""")
+ createMV("""create materialized view mv_sync49 as select id as s1,
variance_samp(kint) ss1 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, variance_samp(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync50 as select id as s2,
var_samp(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, var_samp(kint) from agg_mv_test group by id
order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync51 as select id as s3,
window_funnel(3600 * 3, 'default', kdtm, kint = 1, kint = 2) from agg_mv_test
group by id order by id;""")
mv_rewrite_success("select id, window_funnel(3600 * 3, 'default', kdtm,
kint = 1, kint = 2) from agg_mv_test group by id order by id;", "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;"""
@@ -359,7 +359,7 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync54 as select id as s6,
retention(kdtm = '2012-03-11', kdtm = '2012-03-12') from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, retention(kdtm = '2012-03-11', kdtm =
'2012-03-12') from agg_mv_test group by id order by id;", "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;"""
diff --git
a/regression-test/suites/nereids_syntax_p1/mv/aggregate/agg_sync_mv.groovy
b/regression-test/suites/nereids_syntax_p1/mv/aggregate/agg_sync_mv.groovy
index 8ef34fd7948..7ba87570d9c 100644
--- a/regression-test/suites/nereids_syntax_p1/mv/aggregate/agg_sync_mv.groovy
+++ b/regression-test/suites/nereids_syntax_p1/mv/aggregate/agg_sync_mv.groovy
@@ -24,7 +24,7 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync1 as select id as a1,
any_value(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, any_value(kint) from agg_mv_test group by
id order by id;", "mv_sync1")
qt_select_any_value_mv """select id, any_value(kint) from agg_mv_test
group by id order by id;"""
@@ -40,207 +40,207 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync3 as select id as a2,
approx_count_distinct(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, approx_count_distinct(kint) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync4 as select id as a3,
collect_set(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, collect_set(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync5 as select id as a4,
collect_list(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, collect_list(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync6 as select id as a5,
corr(kint, kbint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, corr(kint, kbint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync7 as select id as a6,
percentile_array(kint, [0.5,0.55,0.805]) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, percentile_array(kint, [0.5,0.55,0.805])
from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync8 as select id as b1,
quantile_union(to_quantile_state(kbint, 2048)) from agg_mv_test group by id
order by id;""")
mv_rewrite_success("select id, quantile_union(to_quantile_state(kbint,
2048)) from agg_mv_test group by id order by id;",
"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_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;""")
+ createMV("""create materialized view mv_sync9 as select id as b2,
count_by_enum(kstr) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, count_by_enum(kstr) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync10 as select id as b3,
avg_weighted(ktint, kdbl) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, avg_weighted(ktint, kdbl) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync11 as select id as b4,
bitmap_intersect(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, bitmap_intersect(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync12 as select id as b5,
bitmap_agg(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, bitmap_agg(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync13 as select id as b6,
bitmap_union(bitmap_hash(kbint)) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, bitmap_union(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync14 as select id as c1,
bitmap_union_count(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
mv_rewrite_any_success("select id, bitmap_union_count(bitmap_hash(kbint))
from agg_mv_test group by id order by id;", ["mv_sync13", "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_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;""")
+ createMV("""create materialized view mv_sync15 as select id as c2,
bitmap_union_int(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, bitmap_union_int(kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync16 as select id as c3,
group_array_intersect(kaint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_array_intersect(kaint) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync17 as select id as c4,
group_bit_and(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_bit_and(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync18 as select id as c5,
group_bit_or(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_bit_or(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync19 as select id as c6,
group_bit_xor(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, group_bit_xor(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync20 as select id as d1,
group_bitmap_xor(bitmap_hash(kbint)) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, group_bitmap_xor(bitmap_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync21 as select id as d2,
hll_union_agg(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, hll_union_agg(hll_hash(kbint)) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync22 as select id as d3,
hll_union(hll_hash(kbint)) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, hll_union(hll_hash(kbint)) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync23 as select id as d4,
intersect_count(bitmap_hash(kbint), kint, 3, 4) from agg_mv_test group by id
order by id;""")
mv_rewrite_success("select id, intersect_count(bitmap_hash(kbint), kint,
3, 4) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync24 as select id as d5,
group_concat(cast(abs(kint) as varchar)) from agg_mv_test group by id order by
id;""")
mv_rewrite_success("select id, group_concat(cast(abs(kint) as varchar))
from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync25 as select id as d6,
multi_distinct_group_concat(cast(abs(kint) as varchar)) from agg_mv_test group
by id order by id;""")
mv_rewrite_success("select id, multi_distinct_group_concat(cast(abs(kint)
as varchar)) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync26 as select id as e1,
multi_distinct_sum0(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, multi_distinct_sum0(kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync27 as select id as e2,
multi_distinct_sum(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, multi_distinct_sum(kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync28 as select id as e3,
histogram(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, histogram(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync29 as select id as e4,
max_by(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, max_by(kint, kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync30 as select id as e5,
min_by(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, min_by(kint, kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync31 as select id as e6,
multi_distinct_count(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, multi_distinct_count(kint) from agg_mv_test
group by id order by id;", "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_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;""")
- mv_rewrite_success("select id, ndv(kint) from agg_mv_test group by id
order by id;", "mv_sync32")
+ createMV("""create materialized view mv_sync32 as select id as f1,
ndv(kint) as xx1 from agg_mv_test group by id order by id;""")
+ mv_rewrite_any_success("select id, ndv(kint) from agg_mv_test group by id
order by id;", ["mv_sync32", "mv_sync3"])
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_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;""")
+ createMV("""create materialized view mv_sync33 as select id as f2,
covar(kint, kint) as xx2 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, covar(kint, kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync34 as select id as f3,
covar_samp(kint, kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, covar_samp(kint, kint) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync35 as select id as f4,
percentile(kbint, 0.6) as xx3 from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, percentile(kbint, 0.6) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync36 as select id as f5,
percentile_approx(kbint, 0.6) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, percentile_approx(kbint, 0.6) from
agg_mv_test group by id order by id;", "mv_sync36")
qt_select_percentile_approx_mv """select id, percentile_approx(kbint, 0.6)
from agg_mv_test group by id order by id;"""
@@ -256,85 +256,85 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync38 as select id as f6,
sequence_count('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, sequence_count('(?1)(?2)', kdtv2, kint = 1,
kint = 2) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync39 as select id as g1,
sequence_match('(?1)(?2)', kdtv2, kint = 1, kint = 2) from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, sequence_match('(?1)(?2)', kdtv2, kint = 1,
kint = 2) from agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync40 as select id as g2,
stddev(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, stddev(kint) from agg_mv_test group by id
order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync41 as select id as g3,
stddev_pop(kint) as yy1 from agg_mv_test group by id order by id;""")
mv_rewrite_any_success("select id, stddev_pop(kint) from agg_mv_test group
by id order by id;", ["mv_sync40", "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_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;""")
+ createMV("""create materialized view mv_sync42 as select id as g4,
stddev_samp(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, stddev_samp(kint) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync43 as select id as g5,
sum0(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, sum0(kint) from agg_mv_test group by id
order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync44 as select id as g6,
topn(kvchrs1, 3) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, topn(kvchrs1, 3) from agg_mv_test group by
id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync45 as select id as s1,
topn_array(kvchrs1, 3) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, topn_array(kvchrs1, 3) from agg_mv_test
group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync46 as select id as s2,
topn_weighted(kvchrs1, ktint, 3) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, topn_weighted(kvchrs1, ktint, 3) from
agg_mv_test group by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync47 as select id as s3,
variance(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_any_success("select id, variance(kint) from agg_mv_test group
by id order by id;", ["mv_sync47", "mv_sync48"])
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_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;""")
+ createMV("""create materialized view mv_sync48 as select id as s4,
var_pop(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_any_success("select id, var_pop(kint) from agg_mv_test group by
id order by id;", ["mv_sync47", "mv_sync48"])
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_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;""")
+ createMV("""create materialized view mv_sync49 as select id as s5,
variance_samp(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_success("select id, variance_samp(kint) from agg_mv_test group
by id order by id;", "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_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;""")
+ createMV("""create materialized view mv_sync50 as select id as s6,
var_samp(kint) from agg_mv_test group by id order by id;""")
mv_rewrite_any_success("select id, var_samp(kint) from agg_mv_test group
by id order by id;", ["mv_sync49", "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_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;""")
+ createMV("""create materialized view mv_sync51 as select id as q1,
window_funnel(3600 * 3, 'default', kdtm, kint = 1, kint = 2) from agg_mv_test
group by id order by id;""")
mv_rewrite_success("select id, window_funnel(3600 * 3, 'default', kdtm,
kint = 1, kint = 2) from agg_mv_test group by id order by id;", "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;"""
@@ -360,7 +360,7 @@ suite("agg_sync_mv") {
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_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;""")
+ createMV("""create materialized view mv_sync54 as select id as q2,
retention(kdtm = '2012-03-11', kdtm = '2012-03-12') from agg_mv_test group by
id order by id;""")
mv_rewrite_success("select id, retention(kdtm = '2012-03-11', kdtm =
'2012-03-12') from agg_mv_test group by id order by id;", "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;"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
