文档首页/ MapReduce服务 MRS/ 组件操作指南（LTS版）/ 使用HetuEngine/ 配置HetuEngine物化视图/ HetuEngine物化视图SQL示例
更新时间：2024-07-02 GMT+08:00
查看PDF
分享

HetuEngine物化视图SQL示例

物化视图SQL示例请参考表1。

表1 物化视图的操作

操作

功能

物化视图SQL样例

备注

创建物化视图

（创建物化视图时，只创建了物化视图的定义，数据填充需要使用refresh materialized view name刷新物化视图数据）

创建永不过期的物化视图

create materialized view mv.default.mv1 with(storage_table='hive.default.mv11') AS select id from hive.mvschema.t1;

创建有效期为1天不启动自动刷新的物化视图

create materialized view mv.default.mv1 with(storage_table='hive.default.mv11', mv_validity = '24h') AS select id from hive.mvschema.t1;

mv_validity：物化视图的有效期

创建每小时自动刷新一次数据的物化视图

create materialized view mv.default.mv1 with(storage_table='hive.default.mv1', need_auto_refresh = true, mv_validity = '1h', start_refresh_ahead_of_expiry = 0.2, refresh_priority = 3, refresh_duration = '5m') AS select id from hive.mvschema.t1;
  • need_auto_refresh：是否启用自动刷新
  • start_refresh_ahead_of_expiry：刷新任务在“mv_validity*（1-start_refresh_ahead_of_expiry）”的时间触发一次更新状态为“可刷新”
  • refresh_priority：刷新任务优先级
  • refresh_duration：刷新任务的最大允许时间

列举物化视图

列举catalog名为“mv”，schema名为“mvschema”的所有物化视图

show materialized views from mvschema;

mvschema是schema的名称，catalog固定为“mv”

根据子句“LIKE”筛选视图名满足规则运算表达式的物化视图

show MATERIALIZED VIEWs in mvschema tables like '*mvtb_0001';

mvschema是schema的名称

查询物化视图的创建语句

查询mv.default.mv1的物化视图创建语句

show create materialized view mv.default.mv1;

mv1是物化视图的名称

查询物化视图

查询mv.default.mv1的数据

select * from mv.default.mv1;

mv1是物化视图的名称

刷新物化视图

刷新mv.default.mv1的物化视图

refresh materialized view mv.default.mv1;

-

修改物化视图属性

修改mv.default.mv1的物化视图的属性

Alter materialized view mv.mvtestprop.pepa_ss set PROPERTIES refresh_priority = 2;

refresh_priority = 2是物化视图的属性

修改物化视图状态

修改mv.default.mv1的物化视图的状态

alter materialized view mv.default.mv1 set status SUSPEND;

SUSPEND是物化视图的状态，状态还包括：

  • SUSPEND：暂停使用状态，暂停使用的物化视图不会参与改写
  • ENABLE：可使用状态
  • REFRESHING：正在刷新物化视图数据，不可用于改写
  • DISABLE：关闭使用

仅支持ENABLE和SUSPEND相互转换，以及将DISABLE状态修改为SUSPEND或ENABLE

删除物化视图

删除mv.default.mv1的物化视图

drop materialized view mv.default.mv1;

-

启用使用物化视图改写SQL进行优化

在session级别启用使用物化视图改写SQL进行优化

set session materialized_view_rewrite_enabled=true;

-

验证查询是否能通过改写成物化视图进行SQL优化

验证查询SQL语句能否被mv.default.mv1改写优化

verify materialized view mvname(mv.default.mv1) originalsql select id from hive.mvschema.t1;

-

SQL级别使用指定的物化视图进行SQL改写优化

在查询中强制使用mv.default.mv1进行优化

/*+ REWRITE(mv.default.mv1) */ select id from hive.mvschema.t1;

-

SQL级别禁用物化视图进行SQL改写优化

在查询中禁止物化视图进行优化

/*+ NOREWRITE */ select id from hive.mvschema.t1;

-

刷新物化视图元数据信息缓存

同步不同租户间物化视图元数据信息缓存

refresh catalog mv;

-

创建物化视图的“AS SELECT”的子句

创建物化视图的“AS SELECT”的子句不能包含calcite SQL解析和改写功能中的保留关键词，如“default”。如果想要在创建物化视图的“AS SELECT”子句中使用保留关键词，需要遵循以下的任一解决方案：
  • 在创建MV和执行原始查询时，需给默认模式名称添加双引号

    以在“AS SELECT”子句中使用保留关键词“default”为例：

    创建物化视图

    CREATE MATERIALIZED VIEW mv.default.mv1 WITH(storage_table='hive.default.mv11') AS SELECT id FROM hive."default".t1;

    SELECT查询

    SELECT id FROM hive."default".t1;
  • 在Session级别设置相应的catalog和schema，而不是在查询中传递完全限定的名称

    以指定catalogname为“hive”，schemaname为“default”为例：

    USE hive.default;

    创建物化视图

    CREATE MATERIALIZED VIEW mv.default.mv1 WITH(storage_table='hive.default.mv11') AS SELECT id FROM t1;

    SELECT查询

    SELECT id FROM t1;

相关文档