概述

支持数据源

StarRocks支持在以下数据源创建异步物化视图：

• StarRocks内部表（基表支持所有StarRocks表类型）

• External Catalog中的表

  • Hive Catalog

  • Hudi Catalog

  • Iceberg Catalog

  • JDBC Catalog

• 已有异步物化视图

• 已有视图

准备工作

以下示例基于Default Catalog中的两张基表：

• 表goods包含产品IDitem_id1、产品名称item_name和产品价格price。

• 表order_list包含订单IDorder_id、客户IDclient_id和产品IDitem_id2。

其中item_id1与item_id2等价。

建表并导入如下数据。

CREATE DATABASE IF NOT EXISTS test_db;
USE test_db;
CREATE TABLE goods(
    item_id1          INT,
    item_name         STRING,
    price             FLOAT
) DISTRIBUTED BY HASH(item_id1);

INSERT INTO goods
VALUES
    (1001,"apple",6.5),
    (1002,"pear",8.0),
    (1003,"potato",2.2);

CREATE TABLE order_list(
    order_id          INT,
    client_id         INT,
    item_id2          INT,
    order_date        DATE
) DISTRIBUTED BY HASH(order_id);

INSERT INTO order_list
VALUES
    (10001,101,1001,"2022-03-13"),
    (10001,101,1002,"2022-03-13"),
    (10002,103,1002,"2022-03-13"),
    (10002,103,1003,"2022-03-14"),
    (10003,102,1003,"2022-03-14"),
    (10003,102,1001,"2022-03-14");

该示例业务场景需要频繁分析订单总额，则查询需要将两张表关联并调用sum()函数，根据订单ID和总额生成一张新表。除此之外，该业务场景需要每天刷新订单总额。

其查询语句如下。

USE test_db;
SELECT
    order_id,
    sum(goods.price) as total
FROM order_list INNER JOIN goods ON goods.item_id1 = order_list.item_id2
GROUP BY order_id;

基于查询语句创建异步物化视图

您可以通过CREATE MATERIALIZED VIEW语句为特定查询语句创建物化视图。

USE test_db;
CREATE MATERIALIZED VIEW order_mv
DISTRIBUTED BY HASH(`order_id`)
REFRESH ASYNC START('2022-09-01 10:00:00') EVERY (interval 1 day)
AS SELECT
    order_list.order_id,
    sum(goods.price) as total
FROM order_list INNER JOIN goods ON goods.item_id1 = order_list.item_id2
GROUP BY order_id;

修改异步物化视图

您可以通过ALTER MATERIALIZED VIEW命令修改异步物化视图属性。

• 启用被禁用的异步物化视图（将物化视图的状态设置为Active）。

  ALTER MATERIALIZED VIEW test_db.order_mv ACTIVE;

• 修改异步物化视图名称为order_total。

  ALTER MATERIALIZED VIEW test_db.order_mv RENAME order_total;

• 修改异步物化视图的最大刷新间隔为2天。

  ALTER MATERIALIZED VIEW test_db.order_mv REFRESH ASYNC EVERY(INTERVAL 2 DAY);

查看异步物化视图

您可以使用SHOW MATERIALIZED VIEWS或查询Information Schema中的系统元数据视图来查看数据库中的异步物化视图。

• 查看当前数据仓库内所有异步物化视图。

  USE test_db;
  SHOW MATERIALIZED VIEWS;

• 查看特定异步物化视图。

  USE test_db;
  SHOW MATERIALIZED VIEWS WHERE NAME = "order_mv";

• 通过名称匹配查看异步物化视图。

  USE test_db;
  SHOW MATERIALIZED VIEWS WHERE NAME LIKE "order%";

• 通过Information Schema中的系统元数据视图materialized_views查看所有异步物化视图。

  USE test_db;
  SELECT * FROM information_schema.materialized_views;

查看异步物化视图创建语句

您可以通过SHOW CREATE MATERIALIZED VIEW命令查看异步物化视图创建语句。

SHOW CREATE MATERIALIZED VIEW test_db.order_mv;

查看异步物化视图的执行状态

您可以通过以下两种方式查看异步物化视图的执行状态。

• 通过EMR StarRocks Manager的物化视图管理 > 异步物化视图页面进行查看。

• 通过查询StarRocks 的Information Schema中的tasks和task_runs元数据视图来查看异步物化视图的执行（构建或刷新）状态。

  示例如下。

  1. 查看tasks表中最新任务的TASK_NAME。

     SELECT * FROM information_schema.tasks  ORDER BY CREATE_TIME DESC limit 1;

  2. 基于查询到的TASK_NAME在表task_runs中查看执行状态。

     SELECT * FROM information_schema.task_runs WHERE task_name='mv-59299' ORDER BY CREATE_TIME;

删除异步物化视图

您可以通过DROP MATERIALIZED VIEW命令删除已创建的异步物化视图。

DROP MATERIALIZED VIEW test_db.order_mv;