实时计算Flink版：管理Hologres Catalog

创建Hologres表

创建Hologres表时，允许在WITH参数中设置物理表属性，合理的表属性设置可以有助于系统高效地组织和查询数据。当前支持的属性参数和使用示例如下表所示，其中以table_property. 为前缀的是物理表属性。

修改Hologres表

目前Hologres Catalog支持的修改表操作及示例如下：

• 修改表属性

  ALTER TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` SET (
    'table_property.binlog.level' = 'replica',
    'table_property.binlog.ttl' = '64700'
  );

  说明

  仅部分表属性支持修改，详情参考创建Hologres表。

• 重命名表

  ALTER TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` 
  RENAME TO `${catalog_name}`.`${db_name}`.`${schema_name.new_table_name}`;

• 增加列

  ALTER TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` 
  ADD <column_name> <column_datatype> COMMENT '<column_comment>';

• 修改列名

  ALTER TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` 
  RENAME <old_column_name> TO <new_column_name>;

• 修改列注释

  ALTER TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` 
  MODIFY <column_name> <original_column_type> COMMENT '<new_column_comment>';

从Hologres表中读取数据

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${schema_name.table_name}`

写入结果数据至Hologres表

INSERT INTO `${catalog_name}`.`${db_name}`.`${schema_name.table_name}`
SELECT ... 
FROM ${other_source_table}

作为CTAS的目标端Catalog

CREATE TABLE IF NOT EXISTS `${catalog_name}`.`${db_name}`.`${schema_name.table_name}`
WITH (
  'connector' = 'hologres'
) AS TABLE ${other_source_table};

CTAS支持在WITH参数中设置物理表属性，在创建目标表时，同时在表上设置对应的属性。具体支持的表属性参数详情，请参见创建Hologres表。

作为CDAS的目标端Catalog

CREATE DATABASE IF NOT EXISTS `${catalog_name}`.`${db_name}`
WITH (
  'sink.parallelism' = '5' -- 设置每张结果表的并发数。
) AS DATABASE ${other_source_database};

在同步过程之中，您可以在WITH参数声明结果表的参数。当作业启动时，这些参数将被应用到需要同步的下游表中。具体可以调节的参数请参见实时数仓Hologres结果表。