修改dynamic table

Lakehouse 系统支持使用 ALTER 语句对动态表进行运维管理：

• 暂停和启动调度任务：控制由 Lakehouse 系统自动刷新的调度任务。
• 表注释：更新动态表的描述信息。
• 列名：修改现有列的名称。

对于涉及 SQL 查询逻辑变化 的修改（即动态表定义中的 SELECT 加工过程），必须使用 CREATE OR REPLACE 语法。这是因为动态表与普通表不同，其定义包含了数据加工逻辑，而不仅仅是静态结构。以下需要使用CREATE OR REPALCE 语法修改。需要注意的是如果用户不是简单的 删除列 / 添加列添加列定义：只能是从表一路经由SELECT透传的，不能参与任何会影响其他列的计算例如 join key, group key 等。则在 Create Or Replace 发生后，REFRESH任务会退化为一次全量刷新

• 调度周期：调整调度任务的执行频率。
• 计算集群：指定用于处理动态表的计算资源。
• 加列：动态表增加列，涉及到SQL语法结构变化。
• 减列：动态表增减列，涉及到SQL语法结构变化。
• 修改列类型：涉及到SQL语法结构变化。
• 修改动态表中SQL语法定义：涉及到SQL语法结构变化。

语法

暂停Lakehouse系统刷新的调度任务

-- 暂停Lakehouse系统刷新的调度任务
ALTER DYNAMIC TABLE dt_name SUSPEND;

启动Lakehouse系统刷新的调度任务

-- 启动Lakehouse系统刷新的调度任务
ALTER DYNAMIC TABLE dt_name RESUME;

修改表的comment

-- 修改表的comment
ALTER DYNAMIC TABLE dt_name SET COMMENT 'comment';

修改动态表中列的名字

ALTER DYNAMIC TABLE dt_name RENAME COLUMN column_name TO new_column_name;

案例

ALTER DYNAMIC TABLE change_table  RENAME COLUMN i TO ii;

修改动态表中列的comment

ALTER DYNAMIC TABLE table_name CHANGE COLUMN column_name_identifier COMMENT 'comment'

案例

ALTER DYNAMIC TABLE change_table  CHANGE COLUMN ii COMMENT 'comment';

修改表的属性（PROPERTIES）

功能：通过ALTER DYNAMIC TABLE命令，您可以为动态表设置或修改属性。目前为保留参数

语法：

--为动态表设置或修改属性
ALTER DYNAMIC TABLE dt_name SET PROPERTIES("key"="value");
--删除属性
ALTER DYNAMIC TABLE dt_name SET PROPERTIES("key");

案例

--增加属性
ALTER DYNAMIC TABLE dt_name set properties('aa'='bb');
--修改属性
ALTER DYNAMIC TABLE dt_name set properties('aa'='cc');
--删除属性
ALTER DYNAMIC TABLE dt_name unset properties('aa');

修改调度周期

使用OR REPLACE语法，案例如下

--原表
CREATE dynamic TABLE dt_name
REFRESH   interval 10 MINUTE vcluster DEFAULT AS
SELECT    *
FROM      student02;

--修该后
CREATE OR  REPLACE dynamic TABLE dt_name
REFRESH   interval 20 MINUTE vcluster DEFAULT AS
SELECT    *
FROM      student02;

修改计算集群

使用OR REPLACE语法，案例如下

--原表
CREATE dynamic TABLE dt_name
REFRESH   interval 10 MINUTE vcluster DEFAULT AS
SELECT    *
FROM      student02;

--修该后
CREATE OR   REPLACE dynamic TABLE dt_name
REFRESH   interval 10 MINUTE vcluster alter_vc AS
SELECT    *
FROM      student02;

增加列

--创建一个基表
DROP TABLE  IF EXISTS dy_base_a;
CREATE TABLE dy_base_a (i int, j int);
INSERT INTO dy_base_a VALUES
(1,10),
(2,20),
(3,30),
(4,40);
--使用dynamic table进行加工
DROP DYNAMIC TABLE IF EXISTS change_table;

CREATE DYNAMIC TABLE change_table (i, j) AS
SELECT    *
FROM      dy_base_a;

--刷新dynamic table
REFRESH   DYNAMIC TABLE change_table;

--查询数据
SELECT    *
FROM      change_table;
+---+----+
| i | j  |
+---+----+
| 1 | 10 |
| 2 | 20 |
| 3 | 30 |
| 4 | 40 |
+---+----+

--添加一列col
CREATE OR REPLACE DYNAMIC TABLE change_table (i, j, col) AS
SELECT    i,
          j,
          j * 1
FROM      dy_base_a;

--下次刷新会进行全量刷新，因为新增了加工逻辑
REFRESH   DYNAMIC TABLE change_table;
+---+----+-----+
| i | j  | col |
+---+----+-----+
| 1 | 10 | 10  |
| 2 | 20 | 20  |
| 3 | 30 | 30  |
| 4 | 40 | 40  |
+---+----+-----+

减列

DROP      TABLE IF EXISTS dy_base_a;

CREATE    TABLE dy_base_a (i int, j int);

INSERT    INTO dy_base_a
VALUES    (1, 10),
          (2, 20),
          (3, 30),
          (4, 40);

--使用dynamic table进行加工
DROP DYNAMIC TABLE IF EXISTS change_table;

CREATE DYNAMIC TABLE change_table (i, j) AS
SELECT    *
FROM      dy_base_a;

--刷新dynamic table
REFRESH   DYNAMIC TABLE change_table;

--查询数据
SELECT    *
FROM      change_table;
+---+----+
| i | j  |
+---+----+
| 1 | 10 |
| 2 | 20 |
| 3 | 30 |
| 4 | 40 |
+---+----+
 --减列
CREATE OR REPLACE DYNAMIC TABLE change_table (i, j) AS
SELECT    i,
          j
FROM      dy_base_a;

--此时表中查询会少一列，刷新为增量刷新。
SELECT    *
FROM      change_table;
+---+----+
| i | j  |
+---+----+
| 1 | 10 |
| 2 | 20 |
| 3 | 30 |
| 4 | 40 |
+---+----+

修改SQL语法定义

--创建一个基表
DROP      TABLE IF EXISTS dy_base_a;

CREATE    TABLE dy_base_a (i int, j int);

INSERT    INTO dy_base_a
VALUES    (1, 10),
          (2, 20),
          (3, 30),
          (4, 40);
--使用dynamic table进行加工
DROP DYNAMIC TABLE IF EXISTS change_table;

CREATE DYNAMIC TABLE change_table (i, j) AS
SELECT    *
FROM      dy_base_a;

--刷新dynamic table
REFRESH   DYNAMIC TABLE change_table;
--查询数据
SELECT    *
FROM      change_table;
+---+----+
| i | j  |
+---+----+
| 1 | 10 |
| 2 | 20 |
| 3 | 30 |
| 4 | 40 |
+---+----+

--修改where过滤条件
CREATE OR  REPLACE DYNAMIC TABLE change_table (i, j) AS
SELECT    *
FROM      dy_base_a
WHERE     i > 3;

--此时刷新会全量刷新一次
REFRESH   DYNAMIC TABLE change_table;

SELECT    *
FROM      change_table;
+---+----+
| i | j  |
+---+----+
| 4 | 40 |
+---+----+

修改列类型

如果是兼容类型例如int变成bigint。具体兼容类型可以参考修改列类型则会增量刷新

--创建一个基表
DROP      TABLE IF EXISTS dy_base_a;

CREATE    TABLE dy_base_a (i int, j int);

INSERT    INTO dy_base_a
VALUES    (1, 10),
          (2, 20),
          (3, 30),
          (4, 40);

--使用dynamic table进行加工
DROP DYNAMIC TABLE IF EXISTS change_table;

CREATE DYNAMIC TABLE change_table (i, j) AS
SELECT    *
FROM      dy_base_a;

--刷新dynamic table
REFRESH   DYNAMIC TABLE change_table;

--查询数据
SELECT    *
FROM      change_table;
+---+----+
| i | j  |
+---+----+
| 1 | 10 |
| 2 | 20 |
| 3 | 30 |
| 4 | 40 |
+---+----+

--修改列类型，
CREATE OR  REPLACE DYNAMIC TABLE change_table (i, j) AS
SELECT    cast(i AS bigint),
          j
FROM      dy_base_a;

REFRESH   DYNAMIC TABLE change_table;

DESC change_table;
+-------------+-----------+---------+
| column_name | data_type | comment |
+-------------+-----------+---------+
| i           | bigint    |         |
| j           | int       |         |
+-------------+-----------+---------+

使用示例

1.暂停名为"dynamic_sales"的动态表的调度任务：

ALTER DYNAMIC TABLE dynamic_sales SUSPEND;

2. 启动名为"dynamic_inventory"的动态表的调度任务：

ALTER DYNAMIC TABLE dynamic_inventory RESUME;

3.对于设置过refreshOption的动态表dt_name，修改刷新任务使用的计算资源

CREATE dynamic TABLE dt_name
REFRESH   interval 10 MINUTE vcluster DEFAULT AS
SELECT    *
FROM      student02;

CREATE OR  REPLACE dynamic TABLE dt_name
REFRESH   interval 10 MINUTE vcluster alter_vc AS
SELECT    *
FROM      student02;

4.修改已有的动态表comment

ALTER DYNAMIC TABLE bulk_order_items_dt SET COMMENT 'comment';