Realtime Compute for Apache 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結果表。