Doris之ROLLUP

「爱情、让人受尽委屈。」 2022-09-09 10:57 203阅读 0赞

### 1、基本概念 ###

*  Base表（基表）：也就是通过`create table`命令创建出来的表，包括明细表（DUPLICATE ）、聚合表（Aggregate ）、更新表（UNIQUE ）
 *  物化视图（Materialized Views）：简称 MVs，将预先计算（根据定义好的 SELECT 语句）好的数据集，存储在 Doris 中的一个特殊的表。
 *  ROLLUP是物化视图的一个子集。`ALTER TABLE ADD ROLLUP` 语法功能可以通过 `CREATE MATERIALIZED VIEW` 语法实现。
 *  ROLLUP本意是上卷，属于多维分析中的概念，将数据按照某种指定粒度进行聚合。
 *  在 Base 表之上，可以创建多个 ROLLUP表，在物理上是独立存储。
 *  Base 表中的更新表属于特殊的聚合表，可以建立ROLLUP； Duplicate表不能聚合，建立ROLLUP仅仅是作为调整列顺序，以命中前缀索引的作用。

### 2、创建ROLLUP ###

（1）准备数据

MySQL [test]> insert into test.user_visit values("2021-09-01",1,"2021-08-31 11:30:22",12,1,2);
    Query OK, 1 row affected (0.14 sec)
    {'label':'insert_842e8f6967df4032-925ba0c7db659b4c', 'status':'VISIBLE', 'txnId':'240'}
    
    MySQL [test]> insert into test.user_visit values("2021-09-01",2,"2021-08-31 10:31:32",9,3,3);
    Query OK, 1 row affected (0.05 sec)
    {'label':'insert_d671f0dc68144843-bb6f94cc499c1b0e', 'status':'VISIBLE', 'txnId':'241'}
    
    MySQL [test]> insert into test.user_visit values("2021-08-31",2,"2021-08-30 11:32:32",11,2,3);
    Query OK, 1 row affected (0.06 sec)
    {'label':'insert_d2937852f1804868-8ba323356c9f772c', 'status':'VISIBLE', 'txnId':'242'}
    
    MySQL [test]> select * from test.user_visit;
    +------------+---------+---------------------+----------------+----------------+------+
    | dt         | user_id | last_visit          | max_dwell_time | min_dwell_time | pv   |
    +------------+---------+---------------------+----------------+----------------+------+
    | 2021-08-31 |       1 | 2021-08-30 11:30:22 |             10 |              0 |    5 |
    | 2021-09-01 |       1 | 2021-08-31 11:30:22 |             12 |              1 |    2 |
    | 2021-08-31 |       2 | 2021-08-30 11:32:32 |             11 |              2 |    3 |
    | 2021-09-01 |       2 | 2021-08-31 10:31:32 |              9 |              3 |    3 |
    +------------+---------+---------------------+----------------+----------------+------+
    4 rows in set (0.02 sec)
    
    MySQL [test]>

（2）创建ROLLUP

MySQL [test]> alter table test.user_visit add rollup rollup_userid(user_id,pv);
    Query OK, 0 rows affected (0.06 sec)
    
    MySQL [test]>

说明：rollup\_userid是我们创建的ROLLUP名称

（3）查看查询计划

可以看到`rollup: rollup_userid`，表示查询我们刚才创建的ROLLUP

（4）未命中ROLLUP的例子

（5）查询已创建的ROLLUP

MySQL [test]> SHOW ALTER TABLE ROLLUP FROM test \G
    *************************** 1. row ***************************
              JobId: 10453
          TableName: user_visit
         CreateTime: 2021-09-01 15:38:16
         FinishTime: 2021-09-01 15:38:36
      BaseIndexName: user_visit
    RollupIndexName: rollup_userid
           RollupId: 10454
      TransactionId: 243
              State: FINISHED
                Msg: 
           Progress: NULL
            Timeout: 86400
    1 row in set (0.01 sec)
    
    MySQL [test]>