ALTER DYNAMIC TABLE

V3.1语法

--修改refresh的计算资源，可以选择为本地执行或者serverless执行
ALTER DYNAMIC TABLE [ IF EXISTS ] [<schema_name>.]<table_name> 
SET (computing_resource ='[local|serverless]');

--修改serverless的计算资源规格
ALTER DYNAMIC TABLE [ IF EXISTS ] [<schema_name>.]<table_name> 
SET (refresh_guc_hg_experimental_serverless_computing_required_cores='<num>');

V3.0语法

--修改单个表的refresh资源
ALTER DYNAMIC TABLE [ IF EXISTS ] [<schema_name>.]<table_name> 
SET (<incremental/full>_guc_hg_computing_resource ='[local|serverless]');

--如果是serverless模式，还可以修改serverless的计算规格
ALTER DYNAMIC TABLE [ IF EXISTS ] [<schema_name>.]<table_name> 
SET (<incremental/full>_guc_hg_experimental_serverless_computing_required_cores='<num>');

V3.1版本语法

ALTER DYNAMIC TABLE <schema_name>.<table_name> SET (auto_refresh_mode = '<full/auto>');

V3.0版本语法

ALTER DYNAMIC TABLE <schema_name>.<table_name> SET (refresh_mode = 'full');

V3.1版本语法

Hologres自V3.1.18版本开始，Dynamic Table支持修改Query定义，以及在Query中加列实现给Dynamic Table加列。

ALTER DYNAMIC TABLE [ IF NOT EXISTS ] [<schema_name>.]<table_name> 
AS
<query>; -- 新的query的定义

• 使用说明：

  • 对于新Query定义的要求如下：

    • 新的Query生成的Dynamic Table必须和原Query生成的Dynamic Table表结构兼容，包括：

      • 都是分区表或者都是非分区表。

      • 表的PK相同。

      • 表的Distribution Key相同，且不允许修改Distribution Key。

      • 表的Partition Key相同，且不允许修改Partition Key。

      • 表的Clustering Key、Segment Key、表的存储模式（列存、行列共存等）、Dictionary Encoding、Bitmap Index相同。

      • 字段名必须相同，且不能修改字段名。

      • 同名的字段、数据类型相同，NULLABLE属性相同。

    • 只能在Query中ADD Column，不支持DROP Column。新增列，已有数据保持不变，新增的列默认补NULL值，会在下一次Refresh后更新数据。

  • 修改Query定义后，Refresh的行为如下：

    • 非分区Dynamic Table：下一次Refresh时（无论是Auto Refresh还是手动Refresh）会支持Refresh Overwrite。

    • 逻辑分区Dynamic Table：活跃分区在下一次Auto Refresh会自动触发Refresh Overwrite；历史分区需要手动触发一次Refresh。

    修改Query定义后，如果Query中有增量刷新不支持的算子，此时Refresh的行为如下：

    刷新模式	新Query定义支持增量刷新	新Query定义不支持增量刷新
    auto_refresh_mode = 'auto'	保持建表时指定的refresh_mode。	refresh_mode自动变为全量刷新。
    auto_refresh_mode = 'incremental'	保持增量刷新。	刷新报错，需要手动改为全量刷新。
    auto_refresh_mode = 'full'	保持全量刷新。	保持全量刷新。

• 使用示例

  1. 准备示例数据。

     --准备一张源表
     CREATE TABLE employees (
         department_id INT,
         employee_name VARCHAR
     );
     --插入数据
     INSERT INTO employees (department_id, employee_name) VALUES
     (1, 'John'),
     (1, 'Jane'),
     (1, 'John'),  -- 重复值
     (2, 'Alice'),
     (2, 'Bob'),
     (2, 'Alice'); -- 重复值
     
     --创建一张dynamic table
     CREATE  DYNAMIC TABLE dt_employees
     WITH (
       -- dynamic table的属性
       freshness = '1 minutes', 
       auto_refresh_mode = 'auto',
       distribution_key = 'department_id'
     )
     AS 
     SELECT
         department_id
     FROM employees   
     GROUP BY department_id;
     
     --查询dynamic table中的数据
     SELECT * FROM dt_employees;

  2. 对Dynamic Table新增一列。

     --新增一列
     ALTER DYNAMIC TABLE dt_employees
     AS 
     SELECT
         department_id,
        STRING_AGG(DISTINCT employee_name, ', ') AS unique_employees
     FROM employees   
     GROUP BY department_id;
     

     执行成功后查询Dynamic Table的数据，可以看到新增的数据是NULL。

     department_id	｜unique_employees
     -----------｜--------
     1	｜\N
     2	｜\N

     等到下一次Refresh成功后，可以看到新增的列数据已经刷新完成。

     department_id	｜unique_employees
     -------------｜---------
     1	｜Jane, John
     2 ｜	Bob, Alice

V3.0版本语法

Hologres V3.0支持修改Query定义，语法如下，目前仅支持全量模式修改，增量模式暂不支持。

ALTER DYNAMIC TABLE [IF EXISTS] [<schema>.]<table_name> SET (task_definition = $$<new_query>$$);