This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 683b4ef02bc [feature](mtmv)disable mtmv for 2.0 (#26176)
683b4ef02bc is described below
commit 683b4ef02bceadd151a360ec40f03465382aa230
Author: zhangdong <[email protected]>
AuthorDate: Wed Nov 1 19:36:23 2023 +0800
[feature](mtmv)disable mtmv for 2.0 (#26176)
---
.../CreateMultiTableMaterializedViewStmt.java | 6 +-
.../catalog/MultiTableMaterializedViewTest.java | 575 ---------------------
regression-test/data/mtmv_p0/test_create_mtmv.out | 6 -
regression-test/data/mtmv_p0/test_refresh_mtmv.out | 6 -
.../suites/mtmv_p0/ssb/ddl/customer_create.sql | 15 -
.../suites/mtmv_p0/ssb/ddl/customer_delete.sql | 1 -
.../suites/mtmv_p0/ssb/ddl/date_create.sql | 24 -
.../suites/mtmv_p0/ssb/ddl/date_delete.sql | 1 -
.../suites/mtmv_p0/ssb/ddl/lineorder_create.sql | 24 -
.../suites/mtmv_p0/ssb/ddl/lineorder_delete.sql | 1 -
.../mtmv_p0/ssb/ddl/lineorder_flat_create.sql | 45 --
.../mtmv_p0/ssb/ddl/lineorder_flat_delete.sql | 1 -
.../suites/mtmv_p0/ssb/ddl/part_create.sql | 16 -
.../suites/mtmv_p0/ssb/ddl/part_delete.sql | 1 -
.../suites/mtmv_p0/ssb/ddl/ssb_flat_create.sql | 52 --
.../suites/mtmv_p0/ssb/ddl/ssb_q11_create.sql | 12 -
.../suites/mtmv_p0/ssb/ddl/ssb_q12_create.sql | 12 -
.../suites/mtmv_p0/ssb/ddl/ssb_q13_create.sql | 14 -
.../suites/mtmv_p0/ssb/ddl/ssb_q21_create.sql | 15 -
.../suites/mtmv_p0/ssb/ddl/ssb_q22_create.sql | 15 -
.../suites/mtmv_p0/ssb/ddl/ssb_q23_create.sql | 15 -
.../suites/mtmv_p0/ssb/ddl/ssb_q31_create.sql | 21 -
.../suites/mtmv_p0/ssb/ddl/ssb_q32_create.sql | 21 -
.../suites/mtmv_p0/ssb/ddl/ssb_q33_create.sql | 27 -
.../suites/mtmv_p0/ssb/ddl/ssb_q34_create.sql | 26 -
.../suites/mtmv_p0/ssb/ddl/ssb_q41_create.sql | 23 -
.../suites/mtmv_p0/ssb/ddl/ssb_q42_create.sql | 28 -
.../suites/mtmv_p0/ssb/ddl/ssb_q43_create.sql | 24 -
.../suites/mtmv_p0/ssb/ddl/supplier_create.sql | 14 -
.../suites/mtmv_p0/ssb/ddl/supplier_delete.sql | 1 -
.../suites/mtmv_p0/test_alter_mtmv.groovy | 86 ---
.../suites/mtmv_p0/test_create_both_mtmv.groovy | 78 ---
.../suites/mtmv_p0/test_create_mtmv.groovy | 75 ---
.../suites/mtmv_p0/test_refresh_mtmv.groovy | 110 ----
34 files changed, 2 insertions(+), 1389 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMultiTableMaterializedViewStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMultiTableMaterializedViewStmt.java
index ee00efdab0f..1ed3609c325 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMultiTableMaterializedViewStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMultiTableMaterializedViewStmt.java
@@ -24,7 +24,6 @@ import org.apache.doris.catalog.DatabaseIf;
import org.apache.doris.catalog.Env;
import org.apache.doris.catalog.TableIf;
import org.apache.doris.common.AnalysisException;
-import org.apache.doris.common.Config;
import org.apache.doris.common.ErrorCode;
import org.apache.doris.common.ErrorReport;
import org.apache.doris.common.UserException;
@@ -67,9 +66,8 @@ public class CreateMultiTableMaterializedViewStmt extends
CreateTableStmt {
@Override
public void analyze(Analyzer analyzer) throws UserException {
- if (!Config.enable_mtmv) {
- throw new UserException("Multi table materialized view was not
graduated."
- + " You should set `enable_mtmv = true` in fe to enabled
it manually.");
+ if (true) {
+ throw new UserException("Multi table materialized view was not
graduated.");
}
refreshInfo.analyze(analyzer);
queryStmt.setNeedToSql(true);
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/catalog/MultiTableMaterializedViewTest.java
b/fe/fe-core/src/test/java/org/apache/doris/catalog/MultiTableMaterializedViewTest.java
deleted file mode 100644
index 8cb5d14c4a9..00000000000
---
a/fe/fe-core/src/test/java/org/apache/doris/catalog/MultiTableMaterializedViewTest.java
+++ /dev/null
@@ -1,575 +0,0 @@
-// 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.
-
-package org.apache.doris.catalog;
-
-import org.apache.doris.analysis.CreateMultiTableMaterializedViewStmt;
-import org.apache.doris.analysis.DropMaterializedViewStmt;
-import org.apache.doris.analysis.DropTableStmt;
-import org.apache.doris.analysis.MVRefreshInfo;
-import org.apache.doris.analysis.MVRefreshIntervalTriggerInfo;
-import org.apache.doris.analysis.ShowStmt;
-import org.apache.doris.catalog.TableIf.TableType;
-import org.apache.doris.common.Config;
-import org.apache.doris.common.DdlException;
-import org.apache.doris.common.ExceptionChecker;
-import org.apache.doris.common.UserException;
-import org.apache.doris.common.io.DataInputBuffer;
-import org.apache.doris.common.io.DataOutputBuffer;
-import org.apache.doris.common.util.SqlParserUtils;
-import org.apache.doris.common.util.Util;
-import org.apache.doris.qe.ShowExecutor;
-import org.apache.doris.qe.ShowResultSet;
-import org.apache.doris.qe.StmtExecutor;
-import org.apache.doris.thrift.TStorageType;
-import org.apache.doris.utframe.TestWithFeService;
-
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.params.ParameterizedTest;
-import org.junit.jupiter.params.provider.ValueSource;
-
-import java.io.IOException;
-
-public class MultiTableMaterializedViewTest extends TestWithFeService {
-
- @BeforeEach
- protected void setUp() throws Exception {
- createDatabase("test");
- connectContext.setDatabase("default_cluster:test");
- connectContext.getState().reset();
- Config.enable_mtmv = true;
- }
-
- @AfterEach
- public void tearDown() {
- Env.getCurrentEnv().clear();
- }
-
- @Test
- public void testSerialization() throws Exception {
- createTable("create table test.t1 (pk int, v1 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- createTable("create table test.t2 (pk int, v2 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
-
- String sql = "create materialized view mv build immediate refresh
complete "
- + "key (mpk) distributed by hash (mpk) "
- + "as select test.t1.pk as mpk from test.t1, test.t2 where
test.t1.pk = test.t2.pk";
- testSerialization(sql);
-
- sql = "create materialized view mv1 build immediate refresh complete
start with '1:00' next 1 day "
- + "key (mpk) distributed by hash (mpk) "
- + "as select test.t1.pk as mpk from test.t1, test.t2 where
test.t1.pk = test.t2.pk";
- testSerialization(sql);
- }
-
- private void testSerialization(String sql) throws UserException,
IOException {
- MaterializedView mv = createMaterializedView(sql);
- DataOutputBuffer out = new DataOutputBuffer(1024);
- mv.write(out);
- DataInputBuffer in = new DataInputBuffer();
- in.reset(out.getData(), out.getLength());
- MaterializedView other = new MaterializedView();
- other.readFields(in);
-
- Assertions.assertEquals(TableType.MATERIALIZED_VIEW, mv.getType());
- Assertions.assertEquals(mv.getType(), other.getType());
- Assertions.assertEquals(mv.getName(), other.getName());
- Assertions.assertEquals(mv.getQuery(), other.getQuery());
-
- MVRefreshInfo refreshInfo = mv.getRefreshInfo();
- MVRefreshInfo otherRefreshInfo = other.getRefreshInfo();
- Assertions.assertEquals(refreshInfo.isNeverRefresh(),
otherRefreshInfo.isNeverRefresh());
- Assertions.assertEquals(refreshInfo.getRefreshMethod(),
otherRefreshInfo.getRefreshMethod());
-
- Assertions.assertEquals(
- refreshInfo.getTriggerInfo().getRefreshTrigger(),
- otherRefreshInfo.getTriggerInfo().getRefreshTrigger()
- );
-
- MVRefreshIntervalTriggerInfo intervalTrigger =
refreshInfo.getTriggerInfo().getIntervalTrigger();
- MVRefreshIntervalTriggerInfo otherIntervalTrigger =
otherRefreshInfo.getTriggerInfo().getIntervalTrigger();
- if (intervalTrigger == null) {
- Assertions.assertNull(otherIntervalTrigger);
- } else {
- Assertions.assertEquals(intervalTrigger.getStartTime(),
otherIntervalTrigger.getStartTime());
- Assertions.assertEquals(intervalTrigger.getInterval(),
otherIntervalTrigger.getInterval());
- Assertions.assertEquals(intervalTrigger.getTimeUnit(),
otherIntervalTrigger.getTimeUnit());
- }
- }
-
- private MaterializedView createMaterializedView(String sql) throws
UserException {
- CreateMultiTableMaterializedViewStmt stmt =
(CreateMultiTableMaterializedViewStmt) SqlParserUtils
- .parseAndAnalyzeStmt(sql, connectContext);
- MaterializedView mv = (MaterializedView) new OlapTableFactory()
- .init(OlapTableFactory.getTableType(stmt))
- .withTableId(0)
- .withTableName(stmt.getMVName())
- .withKeysType(stmt.getKeysDesc().getKeysType())
- .withSchema(stmt.getColumns())
- .withPartitionInfo(new SinglePartitionInfo())
-
.withDistributionInfo(stmt.getDistributionDesc().toDistributionInfo(stmt.getColumns()))
- .withExtraParams(stmt)
- .build();
- mv.setBaseIndexId(1);
- mv.setIndexMeta(
- 1,
- stmt.getMVName(),
- stmt.getColumns(),
- 0,
- Util.generateSchemaHash(),
- Env.calcShortKeyColumnCount(stmt.getColumns(),
stmt.getProperties(), true),
- TStorageType.COLUMN,
- stmt.getKeysDesc().getKeysType());
- return mv;
- }
-
- @Test
- void testShowCreateTables() throws Exception {
- createTable("create table test.t1 (pk int, v1 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- createTable("create table test.t2 (pk int, v2 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- new StmtExecutor(connectContext, "create materialized view mv "
- + "build immediate refresh complete key (mpk) distributed by
hash (mpk) "
- + "properties ('replication_num' = '1') "
- + "as select test.t1.pk as mpk from test.t1, test.t2 where
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- ShowExecutor showExecutor = new ShowExecutor(connectContext,
- (ShowStmt) parseAndAnalyzeStmt("show create table mv"));
- ShowResultSet resultSet = showExecutor.execute();
- String result = resultSet.getResultRows().get(0).get(1);
- Assertions.assertTrue(result.contains("CREATE MATERIALIZED VIEW `mv`\n"
- + "BUILD IMMEDIATE REFRESH COMPLETE ON DEMAND\n"
- + "KEY(`mpk`)\n"
- + "DISTRIBUTED BY HASH(`mpk`) BUCKETS 10"));
- }
-
- @Test
- void testDropMaterializedView() throws Exception {
- createTable("create table test.t1 (pk int, v1 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- createTable("create table test.t2 (pk int, v2 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- new StmtExecutor(connectContext, "create materialized view mv "
- + "build immediate refresh complete key (mpk) distributed by
hash (mpk) "
- + "properties ('replication_num' = '1') "
- + "as select test.t1.pk as mpk from test.t1, test.t2 where
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- ExceptionChecker.expectThrowsWithMsg(DdlException.class, "is not
TABLE",
- () -> Env.getCurrentInternalCatalog()
- .dropTable((DropTableStmt) parseAndAnalyzeStmt("drop
table mv")));
-
- ExceptionChecker.expectThrowsNoException(() ->
connectContext.getEnv().dropMaterializedView(
- (DropMaterializedViewStmt) parseAndAnalyzeStmt("drop
materialized view mv")));
- }
-
- @ParameterizedTest
- @ValueSource(strings = {"AGGREGATE", "UNIQUE", "DUPLICATE"})
- public void testCreate(String keyType) throws Exception {
- String aggregation = keyType.equals("AGGREGATE") ? "SUM" : "";
- createTable("CREATE TABLE test.t1 ("
- + " pk INT,"
- + " v1 INT " + aggregation
- + ") " + keyType + " KEY (pk)"
- + "DISTRIBUTED BY HASH(pk) BUCKETS 1 PROPERTIES
('replication_num' = '1')");
- createTable("CREATE TABLE test.t2 ("
- + " pk INT,"
- + " v2 INT " + aggregation
- + ") " + keyType + " KEY (pk)"
- + "DISTRIBUTED BY HASH(pk) BUCKETS 1 PROPERTIES
('replication_num' = '1')");
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE KEY (pk) DISTRIBUTED BY
HASH(pk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.pk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- connectContext.getEnv().dropMaterializedView(
- (DropMaterializedViewStmt) parseAndAnalyzeStmt("DROP
MATERIALIZED VIEW mv"));
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE DISTRIBUTED BY HASH(pk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.pk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- }
-
- @ParameterizedTest
- @ValueSource(strings = {"AGGREGATE", "UNIQUE", "DUPLICATE"})
- public void testCreateWithAliases(String keyType) throws Exception {
- String aggregation = keyType.equals("AGGREGATE") ? "SUM" : "";
- createTable("CREATE TABLE test.t1 ("
- + " pk INT,"
- + " v1 INT " + aggregation
- + ") " + keyType + " KEY (pk)"
- + "DISTRIBUTED BY HASH(pk) BUCKETS 1 PROPERTIES
('replication_num' = '1')");
- createTable("CREATE TABLE test.t2 ("
- + " pk INT,"
- + " v2 INT " + aggregation
- + ") " + keyType + " KEY (pk)"
- + "DISTRIBUTED BY HASH(pk) BUCKETS 1 PROPERTIES
('replication_num' = '1')");
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE KEY (mpk) DISTRIBUTED BY
HASH(mpk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.pk AS mpk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- connectContext.getEnv().dropMaterializedView(
- (DropMaterializedViewStmt) parseAndAnalyzeStmt("DROP
MATERIALIZED VIEW mv"));
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE DISTRIBUTED BY HASH(mpk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.pk as mpk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- }
-
- @ParameterizedTest
- @ValueSource(strings = {"AGGREGATE", "UNIQUE", "DUPLICATE"})
- public void testCreateWithPartition(String keyType) throws Exception {
- String aggregation = keyType.equals("AGGREGATE") ? "SUM" : "";
- createTable("CREATE TABLE test.t1 ("
- + " pk INT NOT NULL,"
- + " v1 INT " + aggregation
- + ") " + keyType + " KEY (pk)"
- + "PARTITION BY RANGE(pk) ("
- + " PARTITION p1 VALUES LESS THAN ('10'),"
- + " PARTITION p2 VALUES LESS THAN ('20')"
- + ")"
- + "DISTRIBUTED BY HASH(pk) BUCKETS 1 PROPERTIES
('replication_num' = '1')");
- createTable("CREATE TABLE test.t2 ("
- + " pk INT NOT NULL,"
- + " v2 INT " + aggregation
- + ") " + keyType + " KEY (pk)"
- + "PARTITION BY LIST(pk) ("
- + " PARTITION odd VALUES IN ('10', '30', '50', '70', '90'),"
- + " PARTITION even VALUES IN ('20', '40', '60', '80')"
- + ")"
- + "DISTRIBUTED BY HASH(pk) BUCKETS 1 PROPERTIES
('replication_num' = '1')");
-
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE KEY (pk) "
- + "PARTITION BY (t1.pk)"
- + "DISTRIBUTED BY HASH(pk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.pk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- connectContext.getEnv().dropMaterializedView(
- (DropMaterializedViewStmt) parseAndAnalyzeStmt("DROP
MATERIALIZED VIEW mv"));
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE KEY (pk) "
- + "PARTITION BY (t2.pk)"
- + "DISTRIBUTED BY HASH(pk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t2.pk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- connectContext.getEnv().dropMaterializedView(
- (DropMaterializedViewStmt) parseAndAnalyzeStmt("DROP
MATERIALIZED VIEW mv"));
-
- connectContext.getState().reset();
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE KEY (pk) "
- + "PARTITION BY (t1.pk)"
- + "DISTRIBUTED BY HASH(pk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t2.pk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertTrue(
- connectContext.getState().getErrorMessage().contains("Failed
to map the partition column name"));
-
- connectContext.getState().reset();
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE KEY (pk) "
- + "PARTITION BY (v1)"
- + "DISTRIBUTED BY HASH(pk) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t2.pk, v1, v2 FROM test.t1, test.t2 WHERE
test.t1.pk = test.t2.pk").execute();
- Assertions.assertTrue(
- connectContext.getState().getErrorMessage()
- .contains("The partition columns doesn't match the
ones in base table"));
- }
-
- @Test
- public void testCreateWithTableAliases() throws Exception {
- createTable("CREATE TABLE t_user ("
- + " event_day DATE,"
- + " id bigint,"
- + " username varchar(20)"
- + ")"
- + "DISTRIBUTED BY HASH(id) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1')"
- );
- createTable("CREATE TABLE t_user_pv("
- + " event_day DATE,"
- + " id bigint,"
- + " pv bigint"
- + ")"
- + "DISTRIBUTED BY HASH(id) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1')"
- );
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE "
- + "START WITH \"2022-10-27 19:35:00\" "
- + "NEXT 1 SECOND "
- + "KEY (username) "
- + "DISTRIBUTED BY HASH(username) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.username ,t2.pv FROM t_user t1 LEFT JOIN
t_user_pv t2 on t1.id = t2.id").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- }
-
- @Test
- public void testCreateWithHint() throws Exception {
- createTable("CREATE TABLE t_user ("
- + " event_day DATE,"
- + " id bigint,"
- + " username varchar(20)"
- + ")"
- + "DISTRIBUTED BY HASH(id) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1')"
- );
- createTable("CREATE TABLE t_user_pv("
- + " event_day DATE,"
- + " id bigint,"
- + " pv bigint"
- + ")"
- + "DISTRIBUTED BY HASH(id) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1')"
- );
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE "
- + "DISTRIBUTED BY HASH(username) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT /*+ SET_VAR(exec_mem_limit=1048576,
query_timeout=3600) */ "
- + "t1.username ,t2.pv FROM t_user t1 LEFT JOIN t_user_pv t2 on
t1.id = t2.id").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- ShowExecutor showExecutor = new ShowExecutor(connectContext,
- (ShowStmt) parseAndAnalyzeStmt("show create table mv"));
- ShowResultSet resultSet = showExecutor.execute();
- String result = resultSet.getResultRows().get(0).get(1);
- Assertions.assertTrue(
- result.contains("SELECT /*+ SET_VAR(exec_mem_limit=1048576,
query_timeout=3600) */")
- || result.contains("SELECT /*+
SET_VAR(query_timeout=3600, exec_mem_limit=1048576) */")
- );
- }
-
- @Test
- public void testCreateWithViews() throws Exception {
- createTable("CREATE TABLE lineorder ("
- + " lo_orderkey int,"
- + " lo_linenumber int,"
- + " lo_custkey int,"
- + " lo_partkey int,"
- + " lo_suppkey int,"
- + " lo_orderdate int,"
- + " lo_orderpriority int,"
- + " lo_shippriority int,"
- + " lo_quantity int,"
- + " lo_extendedprice int,"
- + " lo_ordtotalprice int,"
- + " lo_discount int,"
- + " lo_revenue int,"
- + " lo_supplycost int,"
- + " lo_tax int,"
- + " lo_commitdate int,"
- + " lo_shipmode int)"
- + "DUPLICATE KEY (lo_orderkey)"
- + "PARTITION BY RANGE (lo_orderdate) ("
- + " PARTITION p1 VALUES [(\"-2147483648\"), (\"19930101\")),"
- + " PARTITION p2 VALUES [(\"19930101\"), (\"19940101\")),"
- + " PARTITION p3 VALUES [(\"19940101\"), (\"19950101\")),"
- + " PARTITION p4 VALUES [(\"19950101\"), (\"19960101\")),"
- + " PARTITION p5 VALUES [(\"19960101\"), (\"19970101\")),"
- + " PARTITION p6 VALUES [(\"19970101\"), (\"19980101\")),"
- + " PARTITION p7 VALUES [(\"19980101\"), (\"19990101\")))"
- + "DISTRIBUTED BY HASH(lo_orderkey) BUCKETS 48 "
- + "PROPERTIES ('replication_num' = '1')");
-
- createTable("CREATE TABLE customer ("
- + " c_custkey int,"
- + " c_name varchar,"
- + " c_address varchar,"
- + " c_city varchar,"
- + " c_nation varchar,"
- + " c_region varchar,"
- + " c_phone varchar,"
- + " c_mktsegment varchar)"
- + "DUPLICATE KEY (c_custkey)"
- + "DISTRIBUTED BY HASH (c_custkey) BUCKETS 12 "
- + "PROPERTIES ('replication_num' = '1')");
-
- createTable("CREATE TABLE supplier ("
- + " s_suppkey int,"
- + " s_name varchar,"
- + " s_address varchar,"
- + " s_city varchar,"
- + " s_nation varchar,"
- + " s_region varchar,"
- + " s_phone varchar)"
- + "DUPLICATE KEY (s_suppkey)"
- + "DISTRIBUTED BY HASH (s_suppkey) BUCKETS 12 "
- + "PROPERTIES ('replication_num' = '1')");
-
- createTable("CREATE TABLE part ("
- + " p_partkey int,"
- + " p_name varchar,"
- + " p_mfgr varchar,"
- + " p_category varchar,"
- + " p_brand varchar,"
- + " p_color varchar,"
- + " p_type varchar,"
- + " p_size int,"
- + " p_container varchar)"
- + "DUPLICATE KEY (p_partkey)"
- + "DISTRIBUTED BY HASH (p_partkey) BUCKETS 12 "
- + "PROPERTIES ('replication_num' = '1')");
-
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW ssb_view "
- + "BUILD IMMEDIATE REFRESH COMPLETE "
- + "DISTRIBUTED BY HASH (LO_ORDERKEY) "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT "
- + " LO_ORDERDATE,"
- + " LO_ORDERKEY,"
- + " LO_LINENUMBER,"
- + " LO_CUSTKEY,"
- + " LO_PARTKEY,"
- + " LO_SUPPKEY,"
- + " LO_ORDERPRIORITY,"
- + " LO_SHIPPRIORITY,"
- + " LO_QUANTITY,"
- + " LO_EXTENDEDPRICE,"
- + " LO_ORDTOTALPRICE,"
- + " LO_DISCOUNT,"
- + " LO_REVENUE,"
- + " LO_SUPPLYCOST,"
- + " LO_TAX,"
- + " LO_COMMITDATE,"
- + " LO_SHIPMODE,"
- + " C_NAME,"
- + " C_ADDRESS,"
- + " C_CITY,"
- + " C_NATION,"
- + " C_REGION,"
- + " C_PHONE,"
- + " C_MKTSEGMENT,"
- + " S_NAME,"
- + " S_ADDRESS,"
- + " S_CITY,"
- + " S_NATION,"
- + " S_REGION,"
- + " S_PHONE,"
- + " P_NAME,"
- + " P_MFGR,"
- + " P_CATEGORY,"
- + " P_BRAND,"
- + " P_COLOR,"
- + " P_TYPE,"
- + " P_SIZE,"
- + " P_CONTAINER "
- + "FROM ("
- + " SELECT "
- + " lo_orderkey,"
- + " lo_linenumber,"
- + " lo_custkey,"
- + " lo_partkey,"
- + " lo_suppkey,"
- + " lo_orderdate,"
- + " lo_orderpriority,"
- + " lo_shippriority,"
- + " lo_quantity,"
- + " lo_extendedprice,"
- + " lo_ordtotalprice,"
- + " lo_discount,"
- + " lo_revenue,"
- + " lo_supplycost,"
- + " lo_tax,"
- + " lo_commitdate,"
- + " lo_shipmode"
- + " FROM lineorder"
- + " WHERE lo_orderdate<19930101"
- + ") l "
- + "INNER JOIN customer c ON (c.c_custkey = l.lo_custkey) "
- + "INNER JOIN supplier s ON (s.s_suppkey = l.lo_suppkey) "
- + "INNER JOIN part p ON (p.p_partkey =
l.lo_partkey)").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- }
-
- @Test
- void testCreateNeverRefreshMaterializedView() throws Exception {
- createTable("create table test.t1 (pk int, v1 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- createTable("create table test.t2 (pk int, v2 int sum) aggregate key
(pk) "
- + "distributed by hash (pk) buckets 1 properties
('replication_num' = '1');");
- new StmtExecutor(connectContext, "create materialized view mv "
- + "build immediate never refresh key (mpk) distributed by hash
(mpk) "
- + "properties ('replication_num' = '1') "
- + "as select test.t1.pk as mpk from test.t1, test.t2 where
test.t1.pk = test.t2.pk").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
-
- ShowExecutor showExecutor = new ShowExecutor(connectContext,
- (ShowStmt) parseAndAnalyzeStmt("show create table mv"));
- ShowResultSet resultSet = showExecutor.execute();
- String result = resultSet.getResultRows().get(0).get(1);
- Assertions.assertTrue(result.contains("CREATE MATERIALIZED VIEW `mv`\n"
- + "BUILD IMMEDIATE NEVER REFRESH \n"
- + "KEY(`mpk`)\n"
- + "DISTRIBUTED BY HASH(`mpk`) BUCKETS 10"));
- }
-
- @Test
- void testCreateWithStar() throws Exception {
- createTable("CREATE TABLE t_user ("
- + " event_day DATE,"
- + " id bigint,"
- + " username varchar(20)"
- + ")"
- + "DISTRIBUTED BY HASH(id) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1')"
- );
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD IMMEDIATE REFRESH COMPLETE "
- + "START WITH \"2022-10-27 19:35:00\" "
- + "NEXT 1 SECOND "
- + "DISTRIBUTED BY HASH(username) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.* FROM t_user t1").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- }
-
- @Test
- void testCreateWithoutRefreshInfo() throws Exception {
- createTable("CREATE TABLE t_user ("
- + " event_day DATE,"
- + " id bigint,"
- + " username varchar(20)"
- + ")"
- + "DISTRIBUTED BY HASH(id) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1')"
- );
- new StmtExecutor(connectContext, "CREATE MATERIALIZED VIEW mv "
- + "BUILD DEFERRED "
- + "DISTRIBUTED BY HASH(username) BUCKETS 10 "
- + "PROPERTIES ('replication_num' = '1') "
- + "AS SELECT t1.* FROM t_user t1").execute();
- Assertions.assertNull(connectContext.getState().getErrorCode(),
connectContext.getState().getErrorMessage());
- }
-}
diff --git a/regression-test/data/mtmv_p0/test_create_mtmv.out
b/regression-test/data/mtmv_p0/test_create_mtmv.out
deleted file mode 100644
index 75d55317997..00000000000
--- a/regression-test/data/mtmv_p0/test_create_mtmv.out
+++ /dev/null
@@ -1,6 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !select --
-clz 200
-lisi 300
-zhangsang 200
-
diff --git a/regression-test/data/mtmv_p0/test_refresh_mtmv.out
b/regression-test/data/mtmv_p0/test_refresh_mtmv.out
deleted file mode 100644
index 75d55317997..00000000000
--- a/regression-test/data/mtmv_p0/test_refresh_mtmv.out
+++ /dev/null
@@ -1,6 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !select --
-clz 200
-lisi 300
-zhangsang 200
-
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/customer_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/customer_create.sql
deleted file mode 100644
index d13101b70e0..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/customer_create.sql
+++ /dev/null
@@ -1,15 +0,0 @@
-CREATE TABLE IF NOT EXISTS `customer` (
- `c_custkey` int(11) NOT NULL COMMENT "",
- `c_name` varchar(26) NOT NULL COMMENT "",
- `c_address` varchar(41) NOT NULL COMMENT "",
- `c_city` varchar(11) NOT NULL COMMENT "",
- `c_nation` varchar(16) NOT NULL COMMENT "",
- `c_region` varchar(13) NOT NULL COMMENT "",
- `c_phone` varchar(16) NOT NULL COMMENT "",
- `c_mktsegment` varchar(11) NOT NULL COMMENT ""
-)
-UNIQUE KEY (`c_custkey`)
-DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 1
-PROPERTIES (
-"replication_num" = "1"
-);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/customer_delete.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/customer_delete.sql
deleted file mode 100644
index fe22a226fed..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/customer_delete.sql
+++ /dev/null
@@ -1 +0,0 @@
-truncate table customer;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/date_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/date_create.sql
deleted file mode 100644
index 390905ebea5..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/date_create.sql
+++ /dev/null
@@ -1,24 +0,0 @@
-CREATE TABLE IF NOT EXISTS `dates` (
- `d_datekey` int(11) NOT NULL COMMENT "",
- `d_date` varchar(20) NOT NULL COMMENT "",
- `d_dayofweek` varchar(10) NOT NULL COMMENT "",
- `d_month` varchar(11) NOT NULL COMMENT "",
- `d_year` int(11) NOT NULL COMMENT "",
- `d_yearmonthnum` int(11) NOT NULL COMMENT "",
- `d_yearmonth` varchar(9) NOT NULL COMMENT "",
- `d_daynuminweek` int(11) NOT NULL COMMENT "",
- `d_daynuminmonth` int(11) NOT NULL COMMENT "",
- `d_daynuminyear` int(11) NOT NULL COMMENT "",
- `d_monthnuminyear` int(11) NOT NULL COMMENT "",
- `d_weeknuminyear` int(11) NOT NULL COMMENT "",
- `d_sellingseason` varchar(14) NOT NULL COMMENT "",
- `d_lastdayinweekfl` int(11) NOT NULL COMMENT "",
- `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "",
- `d_holidayfl` int(11) NOT NULL COMMENT "",
- `d_weekdayfl` int(11) NOT NULL COMMENT ""
-)
-UNIQUE KEY (`d_datekey`)
-DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1
-PROPERTIES (
-"replication_num" = "1"
-);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/date_delete.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/date_delete.sql
deleted file mode 100644
index 3841d4617ae..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/date_delete.sql
+++ /dev/null
@@ -1 +0,0 @@
-truncate table `dates`;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_create.sql
deleted file mode 100644
index c066ea8a0d7..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_create.sql
+++ /dev/null
@@ -1,24 +0,0 @@
-CREATE TABLE IF NOT EXISTS `lineorder` (
- `lo_orderkey` bigint(20) NOT NULL COMMENT "",
- `lo_linenumber` bigint(20) NOT NULL COMMENT "",
- `lo_custkey` int(11) NOT NULL COMMENT "",
- `lo_partkey` int(11) NOT NULL COMMENT "",
- `lo_suppkey` int(11) NOT NULL COMMENT "",
- `lo_orderdate` int(11) NOT NULL COMMENT "",
- `lo_orderpriority` varchar(16) NOT NULL COMMENT "",
- `lo_shippriority` int(11) NOT NULL COMMENT "",
- `lo_quantity` bigint(20) NOT NULL COMMENT "",
- `lo_extendedprice` bigint(20) NOT NULL COMMENT "",
- `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "",
- `lo_discount` bigint(20) NOT NULL COMMENT "",
- `lo_revenue` bigint(20) NOT NULL COMMENT "",
- `lo_supplycost` bigint(20) NOT NULL COMMENT "",
- `lo_tax` bigint(20) NOT NULL COMMENT "",
- `lo_commitdate` bigint(20) NOT NULL COMMENT "",
- `lo_shipmode` varchar(11) NOT NULL COMMENT ""
-)
-UNIQUE KEY (`lo_orderkey`, `lo_linenumber`)
-DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 1
-PROPERTIES (
-"replication_num" = "1"
-);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_delete.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_delete.sql
deleted file mode 100644
index 329e040060e..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_delete.sql
+++ /dev/null
@@ -1 +0,0 @@
-truncate table lineorder;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_flat_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_flat_create.sql
deleted file mode 100644
index 35faee0786c..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_flat_create.sql
+++ /dev/null
@@ -1,45 +0,0 @@
-CREATE TABLE IF NOT EXISTS `lineorder_flat` (
- `LO_ORDERDATE` date NOT NULL COMMENT "",
- `LO_ORDERKEY` int(11) NOT NULL COMMENT "",
- `LO_LINENUMBER` tinyint(4) NOT NULL COMMENT "",
- `LO_CUSTKEY` int(11) NOT NULL COMMENT "",
- `LO_PARTKEY` int(11) NOT NULL COMMENT "",
- `LO_SUPPKEY` int(11) NOT NULL COMMENT "",
- `LO_ORDERPRIORITY` varchar(100) NOT NULL COMMENT "",
- `LO_SHIPPRIORITY` tinyint(4) NOT NULL COMMENT "",
- `LO_QUANTITY` tinyint(4) NOT NULL COMMENT "",
- `LO_EXTENDEDPRICE` int(11) NOT NULL COMMENT "",
- `LO_ORDTOTALPRICE` int(11) NOT NULL COMMENT "",
- `LO_DISCOUNT` tinyint(4) NOT NULL COMMENT "",
- `LO_REVENUE` int(11) NOT NULL COMMENT "",
- `LO_SUPPLYCOST` int(11) NOT NULL COMMENT "",
- `LO_TAX` tinyint(4) NOT NULL COMMENT "",
- `LO_COMMITDATE` date NOT NULL COMMENT "",
- `LO_SHIPMODE` varchar(100) NOT NULL COMMENT "",
- `C_NAME` varchar(100) NOT NULL COMMENT "",
- `C_ADDRESS` varchar(100) NOT NULL COMMENT "",
- `C_CITY` varchar(100) NOT NULL COMMENT "",
- `C_NATION` varchar(100) NOT NULL COMMENT "",
- `C_REGION` varchar(100) NOT NULL COMMENT "",
- `C_PHONE` varchar(100) NOT NULL COMMENT "",
- `C_MKTSEGMENT` varchar(100) NOT NULL COMMENT "",
- `S_NAME` varchar(100) NOT NULL COMMENT "",
- `S_ADDRESS` varchar(100) NOT NULL COMMENT "",
- `S_CITY` varchar(100) NOT NULL COMMENT "",
- `S_NATION` varchar(100) NOT NULL COMMENT "",
- `S_REGION` varchar(100) NOT NULL COMMENT "",
- `S_PHONE` varchar(100) NOT NULL COMMENT "",
- `P_NAME` varchar(100) NOT NULL COMMENT "",
- `P_MFGR` varchar(100) NOT NULL COMMENT "",
- `P_CATEGORY` varchar(100) NOT NULL COMMENT "",
- `P_BRAND` varchar(100) NOT NULL COMMENT "",
- `P_COLOR` varchar(100) NOT NULL COMMENT "",
- `P_TYPE` varchar(100) NOT NULL COMMENT "",
- `P_SIZE` tinyint(4) NOT NULL COMMENT "",
- `P_CONTAINER` varchar(100) NOT NULL COMMENT ""
-) ENGINE=OLAP
-UNIQUE KEY(`LO_ORDERDATE`, `LO_ORDERKEY`, `LO_LINENUMBER`)
-DISTRIBUTED BY HASH(`LO_ORDERKEY`) BUCKETS 1
-PROPERTIES (
-"replication_num" = "1"
-);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_flat_delete.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_flat_delete.sql
deleted file mode 100644
index 13f6c32bb65..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/lineorder_flat_delete.sql
+++ /dev/null
@@ -1 +0,0 @@
-truncate table lineorder_flat;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/part_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/part_create.sql
deleted file mode 100644
index 2405026a3cd..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/part_create.sql
+++ /dev/null
@@ -1,16 +0,0 @@
-CREATE TABLE IF NOT EXISTS `part` (
- `p_partkey` int(11) NOT NULL COMMENT "",
- `p_name` varchar(23) NOT NULL COMMENT "",
- `p_mfgr` varchar(7) NOT NULL COMMENT "",
- `p_category` varchar(8) NOT NULL COMMENT "",
- `p_brand` varchar(10) NOT NULL COMMENT "",
- `p_color` varchar(12) NOT NULL COMMENT "",
- `p_type` varchar(26) NOT NULL COMMENT "",
- `p_size` int(11) NOT NULL COMMENT "",
- `p_container` varchar(11) NOT NULL COMMENT ""
-)
-UNIQUE KEY (`p_partkey`)
-DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 1
-PROPERTIES (
-"replication_num" = "1"
-);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/part_delete.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/part_delete.sql
deleted file mode 100644
index 02c6abd2539..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/part_delete.sql
+++ /dev/null
@@ -1 +0,0 @@
-truncate table `part`;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_flat_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_flat_create.sql
deleted file mode 100644
index e5cbc1a5562..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_flat_create.sql
+++ /dev/null
@@ -1,52 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_flat
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(lo_orderkey) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT
- LO_ORDERDATE,
- LO_ORDERKEY,
- LO_LINENUMBER,
- LO_CUSTKEY,
- LO_PARTKEY,
- LO_SUPPKEY,
- LO_ORDERPRIORITY,
- LO_SHIPPRIORITY,
- LO_QUANTITY,
- LO_EXTENDEDPRICE,
- LO_ORDTOTALPRICE,
- LO_DISCOUNT,
- LO_REVENUE,
- LO_SUPPLYCOST,
- LO_TAX,
- LO_COMMITDATE,
- LO_SHIPMODE,
- C_NAME,
- C_ADDRESS,
- C_CITY,
- C_NATION,
- C_REGION,
- C_PHONE,
- C_MKTSEGMENT,
- S_NAME,
- S_ADDRESS,
- S_CITY,
- S_NATION,
- S_REGION,
- S_PHONE,
- P_NAME,
- P_MFGR,
- P_CATEGORY,
- P_BRAND,
- P_COLOR,
- P_TYPE,
- P_SIZE,
- P_CONTAINER
-FROM
-lineorder as l
-INNER JOIN customer c
-ON (c.c_custkey = l.lo_custkey)
-INNER JOIN supplier s
-ON (s.s_suppkey = l.lo_suppkey)
-INNER JOIN part p
-ON (p.p_partkey = l.lo_partkey);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q11_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q11_create.sql
deleted file mode 100644
index fdf1a1462f3..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q11_create.sql
+++ /dev/null
@@ -1,12 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q11
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(REVENUE) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT SUM(lo_extendedprice * lo_discount) AS REVENUE
-FROM lineorder, dates
-WHERE
- lo_orderdate = d_datekey
- AND d_year = 1993
- AND lo_discount BETWEEN 1 AND 3
- AND lo_quantity < 25;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q12_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q12_create.sql
deleted file mode 100644
index fcf1fbd9310..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q12_create.sql
+++ /dev/null
@@ -1,12 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q12
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(REVENUE) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT SUM(lo_extendedprice * lo_discount) AS REVENUE
-FROM lineorder, dates
-WHERE
- lo_orderdate = d_datekey
- AND d_year = 1993
- AND lo_discount BETWEEN 1 AND 3
- AND lo_quantity < 25;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q13_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q13_create.sql
deleted file mode 100644
index 2da36bc129c..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q13_create.sql
+++ /dev/null
@@ -1,14 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q13
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(REVENUE) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT
- SUM(lo_extendedprice * lo_discount) AS REVENUE
-FROM lineorder, dates
-WHERE
- lo_orderdate = d_datekey
- AND d_weeknuminyear = 6
- AND d_year = 1994
- AND lo_discount BETWEEN 5 AND 7
- AND lo_quantity BETWEEN 26 AND 35;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q21_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q21_create.sql
deleted file mode 100644
index 9f0ffc7e10d..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q21_create.sql
+++ /dev/null
@@ -1,15 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q21
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(p_brand) BUCKETS 16
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT SUM(lo_revenue) as revenue, d_year, p_brand
-FROM lineorder, dates, part, supplier
-WHERE
- lo_orderdate = d_datekey
- AND lo_partkey = p_partkey
- AND lo_suppkey = s_suppkey
- AND p_category = 'MFGR#12'
- AND s_region = 'AMERICA'
-GROUP BY d_year, p_brand
-ORDER BY p_brand;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q22_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q22_create.sql
deleted file mode 100644
index 481586e1f4c..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q22_create.sql
+++ /dev/null
@@ -1,15 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q22
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(p_brand) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT SUM(lo_revenue) as lo_revenue, d_year, p_brand
-FROM lineorder, dates, part, supplier
-WHERE
- lo_orderdate = d_datekey
- AND lo_partkey = p_partkey
- AND lo_suppkey = s_suppkey
- AND p_brand BETWEEN 'MFGR#2221' AND 'MFGR#2228'
- AND s_region = 'ASIA'
-GROUP BY d_year, p_brand
-ORDER BY d_year, p_brand;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q23_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q23_create.sql
deleted file mode 100644
index dbaf3bb2343..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q23_create.sql
+++ /dev/null
@@ -1,15 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q23
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(p_brand) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT SUM(lo_revenue) as revenue, d_year, p_brand
-FROM lineorder, dates, part, supplier
-WHERE
- lo_orderdate = d_datekey
- AND lo_partkey = p_partkey
- AND lo_suppkey = s_suppkey
- AND p_brand = 'MFGR#2239'
- AND s_region = 'EUROPE'
-GROUP BY d_year, p_brand
-ORDER BY d_year, p_brand;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q31_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q31_create.sql
deleted file mode 100644
index e757cca4187..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q31_create.sql
+++ /dev/null
@@ -1,21 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q31
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(c_nation, s_nation) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT
- c_nation,
- s_nation,
- d_year,
- SUM(lo_revenue) AS REVENUE
-FROM customer, lineorder, supplier, dates
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_orderdate = d_datekey
- AND c_region = 'ASIA'
- AND s_region = 'ASIA'
- AND d_year >= 1992
- AND d_year <= 1997
-GROUP BY c_nation, s_nation, d_year
-ORDER BY d_year ASC, REVENUE DESC;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q32_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q32_create.sql
deleted file mode 100644
index fdbcd11d059..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q32_create.sql
+++ /dev/null
@@ -1,21 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q32
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(c_city, s_city) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT
- c_city,
- s_city,
- d_year,
- SUM(lo_revenue) AS REVENUE
-FROM customer, lineorder, supplier, dates
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_orderdate = d_datekey
- AND c_nation = 'UNITED STATES'
- AND s_nation = 'UNITED STATES'
- AND d_year >= 1992
- AND d_year <= 1997
-GROUP BY c_city, s_city, d_year
-ORDER BY d_year ASC, REVENUE DESC;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q33_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q33_create.sql
deleted file mode 100644
index a23ef06708f..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q33_create.sql
+++ /dev/null
@@ -1,27 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q33
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(c_city, s_city) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT
- c_city,
- s_city,
- d_year,
- SUM(lo_revenue) AS REVENUE
-FROM customer, lineorder, supplier, dates
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_orderdate = d_datekey
- AND (
- c_city = 'UNITED KI1'
- OR c_city = 'UNITED KI5'
- )
- AND (
- s_city = 'UNITED KI1'
- OR s_city = 'UNITED KI5'
- )
- AND d_year >= 1992
- AND d_year <= 1997
-GROUP BY c_city, s_city, d_year
-ORDER BY d_year ASC, REVENUE DESC;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q34_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q34_create.sql
deleted file mode 100644
index 452fa67a79e..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q34_create.sql
+++ /dev/null
@@ -1,26 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q34
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(c_city, s_city) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT
- c_city,
- s_city,
- d_year,
- SUM(lo_revenue) AS REVENUE
-FROM customer, lineorder, supplier, dates
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_orderdate = d_datekey
- AND (
- c_city = 'UNITED KI1'
- OR c_city = 'UNITED KI5'
- )
- AND (
- s_city = 'UNITED KI1'
- OR s_city = 'UNITED KI5'
- )
- AND d_yearmonth = 'Dec1997'
-GROUP BY c_city, s_city, d_year
-ORDER BY d_year ASC, REVENUE DESC;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q41_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q41_create.sql
deleted file mode 100644
index 33626acf62d..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q41_create.sql
+++ /dev/null
@@ -1,23 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q41
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(c_nation) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=4,
parallel_pipeline_task_num=4, batch_size=4096) */
- d_year,
- c_nation,
- SUM(lo_revenue - lo_supplycost) AS PROFIT
-FROM dates, customer, supplier, part, lineorder
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_partkey = p_partkey
- AND lo_orderdate = d_datekey
- AND c_region = 'AMERICA'
- AND s_region = 'AMERICA'
- AND (
- p_mfgr = 'MFGR#1'
- OR p_mfgr = 'MFGR#2'
- )
-GROUP BY d_year, c_nation
-ORDER BY d_year, c_nation;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q42_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q42_create.sql
deleted file mode 100644
index a6db33e951a..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q42_create.sql
+++ /dev/null
@@ -1,28 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q42
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(s_nation, p_category) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=2,
parallel_pipeline_task_num=2, batch_size=4096) */
- d_year,
- s_nation,
- p_category,
- SUM(lo_revenue - lo_supplycost) AS PROFIT
-FROM dates, customer, supplier, part, lineorder
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_partkey = p_partkey
- AND lo_orderdate = d_datekey
- AND c_region = 'AMERICA'
- AND s_region = 'AMERICA'
- AND (
- d_year = 1997
- OR d_year = 1998
- )
- AND (
- p_mfgr = 'MFGR#1'
- OR p_mfgr = 'MFGR#2'
- )
-GROUP BY d_year, s_nation, p_category
-ORDER BY d_year, s_nation, p_category;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q43_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q43_create.sql
deleted file mode 100644
index 7f8d4311cb7..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/ssb_q43_create.sql
+++ /dev/null
@@ -1,24 +0,0 @@
-CREATE MATERIALIZED VIEW ssb_q43
-BUILD IMMEDIATE REFRESH COMPLETE
-DISTRIBUTED BY HASH(s_city, p_brand) BUCKETS 6
-PROPERTIES ('replication_num' = '1')
-AS
-SELECT /*+SET_VAR(parallel_fragment_exec_instance_num=2,
parallel_pipeline_task_num=2, batch_size=4096) */
- d_year,
- s_city,
- p_brand,
- SUM(lo_revenue - lo_supplycost) AS PROFIT
-FROM dates, customer, supplier, part, lineorder
-WHERE
- lo_custkey = c_custkey
- AND lo_suppkey = s_suppkey
- AND lo_partkey = p_partkey
- AND lo_orderdate = d_datekey
- AND s_nation = 'UNITED STATES'
- AND (
- d_year = 1997
- OR d_year = 1998
- )
- AND p_category = 'MFGR#14'
-GROUP BY d_year, s_city, p_brand
-ORDER BY d_year, s_city, p_brand;
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/supplier_create.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/supplier_create.sql
deleted file mode 100644
index 1580a8fcca4..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/supplier_create.sql
+++ /dev/null
@@ -1,14 +0,0 @@
-CREATE TABLE IF NOT EXISTS `supplier` (
- `s_suppkey` int(11) NOT NULL COMMENT "",
- `s_name` varchar(26) NOT NULL COMMENT "",
- `s_address` varchar(26) NOT NULL COMMENT "",
- `s_city` varchar(11) NOT NULL COMMENT "",
- `s_nation` varchar(16) NOT NULL COMMENT "",
- `s_region` varchar(13) NOT NULL COMMENT "",
- `s_phone` varchar(16) NOT NULL COMMENT ""
-)
-UNIQUE KEY (`s_suppkey`)
-DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 1
-PROPERTIES (
-"replication_num" = "1"
-);
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/ssb/ddl/supplier_delete.sql
b/regression-test/suites/mtmv_p0/ssb/ddl/supplier_delete.sql
deleted file mode 100644
index 39e663134ca..00000000000
--- a/regression-test/suites/mtmv_p0/ssb/ddl/supplier_delete.sql
+++ /dev/null
@@ -1 +0,0 @@
-truncate table `supplier`;
\ No newline at end of file
diff --git a/regression-test/suites/mtmv_p0/test_alter_mtmv.groovy
b/regression-test/suites/mtmv_p0/test_alter_mtmv.groovy
deleted file mode 100644
index 53f90aeffa0..00000000000
--- a/regression-test/suites/mtmv_p0/test_alter_mtmv.groovy
+++ /dev/null
@@ -1,86 +0,0 @@
-// 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.
-
-suite("test_alter_mtmv") {
- def tableName = "t_test_alter_mtmv_user"
- def tableNamePv = "t_test_alter_mtmv_pv"
- def mvName = "multi_mv_test_alter_mtmv"
-
- sql """drop table if exists `${tableName}`"""
- sql """drop table if exists `${tableNamePv}`"""
-
- sql """
- CREATE TABLE IF NOT EXISTS `${tableName}` (
- event_day DATE,
- id BIGINT,
- username VARCHAR(20)
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
- sql """
- INSERT INTO ${tableName}
VALUES("2022-10-26",1,"clz"),("2022-10-28",2,"zhangsang"),("2022-10-29",3,"lisi");
- """
- sql """
- create table IF NOT EXISTS ${tableNamePv}(
- event_day DATE,
- id BIGINT,
- pv BIGINT
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
-
- sql """
- INSERT INTO ${tableNamePv}
VALUES("2022-10-26",1,200),("2022-10-28",2,200),("2022-10-28",3,300);
- """
-
- sql """drop materialized view if exists ${mvName}"""
-
- sql """
- CREATE MATERIALIZED VIEW ${mvName}
- BUILD IMMEDIATE REFRESH COMPLETE
- KEY(username)
- DISTRIBUTED BY HASH (username) buckets 1
- PROPERTIES ('replication_num' = '1')
- AS
- SELECT ${tableName}.username, ${tableNamePv}.pv FROM ${tableName},
${tableNamePv} WHERE ${tableName}.id=${tableNamePv}.id;
- """
-
- // waiting the task to be finished.
- waitingMTMVTaskFinished(mvName)
-
- // test alter mtmv
- sql """
- alter MATERIALIZED VIEW ${mvName} REFRESH COMPLETE start with
"2022-11-03 00:00:00" next 2 DAY
- """
- show_job_meta = sql_meta "SHOW MTMV JOB ON ${mvName}"
- def scheduleIndex = show_job_meta.indexOf(['Schedule', 'CHAR'])
-
- show_job_result = sql "SHOW MTMV JOB ON ${mvName}"
- assertEquals 1, show_job_result.size(), show_job_result.toString()
-
- assertEquals 'START 2022-11-03T00:00 EVERY(2 DAYS)',
show_job_result.last().get(scheduleIndex).toString(),
show_job_result.last().toString()
-
- sql """
- DROP MATERIALIZED VIEW ${mvName}
- """
-}
diff --git a/regression-test/suites/mtmv_p0/test_create_both_mtmv.groovy
b/regression-test/suites/mtmv_p0/test_create_both_mtmv.groovy
deleted file mode 100644
index 4eb9ad2cdec..00000000000
--- a/regression-test/suites/mtmv_p0/test_create_both_mtmv.groovy
+++ /dev/null
@@ -1,78 +0,0 @@
-// 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.
-
-suite("test_create_both_mtmv") {
- def tableName = "t_test_create_both_mtmv_user"
- def tableNamePv = "t_test_create_both_mtmv_user_pv"
- def mvName = "multi_mv_test_create_both_mtmv"
-
- sql """drop table if exists `${tableName}`"""
- sql """drop table if exists `${tableNamePv}`"""
-
- sql """
- CREATE TABLE IF NOT EXISTS `${tableName}` (
- event_day DATE,
- id BIGINT,
- username VARCHAR(20)
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
- sql """
- INSERT INTO ${tableName}
VALUES("2022-10-26",1,"clz"),("2022-10-28",2,"zhangsang"),("2022-10-29",3,"lisi");
- """
- sql """
- create table IF NOT EXISTS ${tableNamePv}(
- event_day DATE,
- id BIGINT,
- pv BIGINT
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
-
- sql """
- INSERT INTO ${tableNamePv}
VALUES("2022-10-26",1,200),("2022-10-28",2,200),("2022-10-28",3,300);
- """
-
- sql """drop materialized view if exists ${mvName}"""
-
- // test only one job created when build IMMEDIATE and start time is before
now.
- sql """
- CREATE MATERIALIZED VIEW ${mvName}
- BUILD IMMEDIATE REFRESH COMPLETE
- start with "2022-11-03 00:00:00" next 1 DAY
- KEY(username)
- DISTRIBUTED BY HASH (username) buckets 1
- PROPERTIES ('replication_num' = '1')
- AS
- SELECT ${tableName}.username, ${tableNamePv}.pv FROM ${tableName},
${tableNamePv} WHERE ${tableName}.id=${tableNamePv}.id;
- """
- // wait task to be finished to avoid task leak in suite.
- waitingMTMVTaskFinished(mvName)
-
- def show_job_result = sql "SHOW MTMV JOB ON ${mvName}"
- assertEquals 1, show_job_result.size(), show_job_result.toString()
-
- sql """
- DROP MATERIALIZED VIEW ${mvName}
- """
-}
diff --git a/regression-test/suites/mtmv_p0/test_create_mtmv.groovy
b/regression-test/suites/mtmv_p0/test_create_mtmv.groovy
deleted file mode 100644
index c3aba28a9ee..00000000000
--- a/regression-test/suites/mtmv_p0/test_create_mtmv.groovy
+++ /dev/null
@@ -1,75 +0,0 @@
-// 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.
-
-suite("test_create_mtmv") {
- def tableName = "t_test_create_mtmv_user"
- def tableNamePv = "t_test_create_mtmv_user_pv"
- def mvName = "multi_mv_test_create_mtmv"
-
- sql """drop table if exists `${tableName}`"""
- sql """drop table if exists `${tableNamePv}`"""
-
- sql """
- CREATE TABLE IF NOT EXISTS `${tableName}` (
- event_day DATE,
- id BIGINT,
- username VARCHAR(20)
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
- sql """
- INSERT INTO ${tableName}
VALUES("2022-10-26",1,"clz"),("2022-10-28",2,"zhangsang"),("2022-10-29",3,"lisi");
- """
- sql """
- create table IF NOT EXISTS ${tableNamePv}(
- event_day DATE,
- id BIGINT,
- pv BIGINT
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
-
- sql """
- INSERT INTO ${tableNamePv}
VALUES("2022-10-26",1,200),("2022-10-28",2,200),("2022-10-28",3,300);
- """
-
- sql """drop materialized view if exists ${mvName}"""
-
- sql """
- CREATE MATERIALIZED VIEW ${mvName}
- BUILD IMMEDIATE REFRESH COMPLETE
- KEY(username)
- DISTRIBUTED BY HASH (username) buckets 1
- PROPERTIES ('replication_num' = '1')
- AS
- SELECT ${tableName}.username, ${tableNamePv}.pv FROM ${tableName},
${tableNamePv} WHERE ${tableName}.id=${tableNamePv}.id;
- """
-
- waitingMTMVTaskFinished(mvName)
-
- order_qt_select "SELECT * FROM ${mvName}"
-
- sql """
- DROP MATERIALIZED VIEW ${mvName}
- """
-}
diff --git a/regression-test/suites/mtmv_p0/test_refresh_mtmv.groovy
b/regression-test/suites/mtmv_p0/test_refresh_mtmv.groovy
deleted file mode 100644
index 70ee205d35c..00000000000
--- a/regression-test/suites/mtmv_p0/test_refresh_mtmv.groovy
+++ /dev/null
@@ -1,110 +0,0 @@
-// 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.
-
-suite("test_refresh_mtmv") {
- def tableName = "t_test_refresh_mtmv_user"
- def tableNamePv = "t_test_refresh_mtmv_user_pv"
- def mvName = "multi_mv_test_refresh_mtmv"
- def mvNameDemand = "multi_mv_test_refresh_demand_mtmv"
-
- sql """drop table if exists `${tableName}`"""
- sql """drop table if exists `${tableNamePv}`"""
-
- sql """
- CREATE TABLE IF NOT EXISTS `${tableName}` (
- event_day DATE,
- id BIGINT,
- username VARCHAR(20)
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
- sql """
- INSERT INTO ${tableName}
VALUES("2022-10-26",1,"clz"),("2022-10-28",2,"zhangsang"),("2022-10-29",3,"lisi");
- """
- sql """
- create table IF NOT EXISTS ${tableNamePv}(
- event_day DATE,
- id BIGINT,
- pv BIGINT
- )
- DISTRIBUTED BY HASH(id) BUCKETS 10
- PROPERTIES (
- "replication_num" = "1"
- );
- """
-
- sql """
- INSERT INTO ${tableNamePv}
VALUES("2022-10-26",1,200),("2022-10-28",2,200),("2022-10-28",3,300);
- """
-
- sql """drop materialized view if exists ${mvName}"""
-
- sql """
- CREATE MATERIALIZED VIEW ${mvName}
- BUILD IMMEDIATE REFRESH COMPLETE
- KEY(username)
- DISTRIBUTED BY HASH (username) buckets 1
- PROPERTIES ('replication_num' = '1')
- AS
- SELECT ${tableName}.username, ${tableNamePv}.pv FROM ${tableName},
${tableNamePv} WHERE ${tableName}.id=${tableNamePv}.id;
- """
-
- // waiting the task to be finished.
- waitingMTMVTaskFinished(mvName)
-
- order_qt_select "SELECT * FROM ${mvName}"
-
- // test REFRESH make sure only define one mv and already run a task.
- sql """
- REFRESH MATERIALIZED VIEW ${mvName} COMPLETE
- """
- waitingMTMVTaskFinished(mvName)
-
- def show_task_result = sql "SHOW MTMV TASK ON ${mvName}"
- assertEquals 2, show_task_result.size(), show_task_result.toString()
-
- sql """
- DROP MATERIALIZED VIEW ${mvName}
- """
-
- sql """drop materialized view if exists ${mvNameDemand}"""
-
- sql """
- CREATE MATERIALIZED VIEW ${mvNameDemand}
- BUILD DEFERRED REFRESH COMPLETE ON DEMAND
- KEY(username)
- DISTRIBUTED BY HASH (username) buckets 1
- PROPERTIES ('replication_num' = '1')
- AS
- SELECT ${tableName}.username, ${tableNamePv}.pv FROM ${tableName},
${tableNamePv} WHERE ${tableName}.id=${tableNamePv}.id;
- """
-
- sql """
- REFRESH MATERIALIZED VIEW ${mvNameDemand} COMPLETE
- """
- waitingMTMVTaskFinished(mvNameDemand)
-
- show_task_result = sql "SHOW MTMV TASK ON ${mvNameDemand}"
- assertEquals 1, show_task_result.size(), show_task_result.toString()
-
- sql """
- DROP MATERIALIZED VIEW ${mvNameDemand}
- """
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
