实时计算Flink版：管理Hologres Catalog

UI方式（推荐）

1. 进入元数据管理页面。

   1. 登录实时计算控制台，在Flink全托管页签，单击目标工作空间操作列下的控制台。

   2. 单击元数据管理。

2. 单击创建Catalog，选择Hologres后，单击下一步。

3. 填写参数配置信息。

   重要

   Catalog创建完成后，以下配置信息都不支持修改。如果需要修改，您需要删除掉已创建的Catalog，重新进行创建。

   

   参数	说明	是否必填
   catalogname	Hologres Catalog名称。	是
   endpoint	Hologres的Endpoint地址。 详情请参见实例配置。	是
   username	阿里云账号的AccessKey。 说明 当前配置的AccessKey对应的用户需要能够访问所有的Hologres数据库，Hologres数据库权限请参见Hologres权限模型概述。	是
   password	阿里云账号的AccessSecret。	是
   dbname	您访问Hologres的默认数据库名称。	是

4. 单击确定。

   说明

   创建完成后，元数据下即可查看新建的Catalog。

SQL方式

1. 在查询脚本文本编辑区域，输入配置Hologres Catalog的命令。

   CREATE CATALOG <catalogname> WITH (
     'type' = 'hologres',
     'endpoint' = '<endpoint>', 
     'username' = '<AccessKey>',
     'password' = '<AccessSecret>',
     'dbname' = '<dbname>'
   );

   参数详情如下表所示。

   参数	说明	是否必填
   catalogname	Hologres Catalog名称。仅支持小写字母a-z和数字0-9，不含大写字母、中划线（-）、下划线（_）等特殊字符	是
   type	类型，固定值为hologres。	是
   endpoint	Hologres的Endpoint地址。 详情请参见实例配置。	是
   username	阿里云账号的AccessKey。 说明 当前配置的AccessKey对应的用户需要能够访问所有的Hologres数据库，Hologres数据库权限请参见Hologres权限模型概述。	是
   password	阿里云账号的AccessSecret。	是
   dbname	您访问Hologres的默认数据库名称。	是
   ignore-non-persisted-options	在使用Hologres Catalog时创建带有不可持久化选项的表时，是否忽略非可持久化选项。参数取值如下： true（默认值）：可以成功创建出表，而忽略所有非可持久化选项。 false：会报创建表失败的错误。 说明 Hologres Catalog表选项的可持久化意味着当再次从Catalog读取该表的相关信息时，可以重新获取您在DDL中定义的一致的信息。目前仅支持endpoint、username、password和dbname可持久化选项。	否
   其他Hologres连接器支持的参数	仅Flink计算引擎VVR 6.0.3-Flink 1.15及以上版本支持，在创建Catalog时可以填入一些参数，包括WITH参数，之后使用此Catalog中的表时，将会默认配置这些参数。 说明 使用此功能，需要ignore-non-persisted-options参数配置为true。 Flink计算引擎VVR 6.0.3-Flink 1.15以下版本只能通过Hints为每张表分别进行参数的配置。	否

2. 选中创建Catalog的代码后，单击左侧代码行数上的运行。

   

UI方式

1. 进入元数据管理页面。

   1. 登录实时计算控制台。

   2. 在Flink全托管页签，单击目标工作空间操作列下的控制台。

   3. 单击元数据管理。

2. 单击目标Catalog名称对应操作列的查看。

3. 单击目标数据库名称对应操作列的查看。

4. 单击创建表。

5. 在使用内置连接器连接页签，单击连接方式，选择表类型。

6. 单击下一步。

7. 填写建表语句并配置相关参数信息。代码示例如下。

   CREATE TABLE `${catalog_name}`.`${db_name}`.`${table_name}` (
    id INT,
    name STRING
   ) WITH (
    'connector' = 'hologres'
   );

8. 单击确定。

SQL命令方式

1. 在查询脚本文本编辑区域，输入以下建表语句。

   通常，有以下几种方式创建Hologres表：

   • 使用USE CATALOG HoloName命令直接引用Hologres数据服务。

     USE CATALOG ${catalog_name};
     CREATE TABLE `${db_name}`.`${schema_name.table_name}`(
       ...
      ) WITH (
        'connector' = 'hologres'
      );

     USE语法详情请参见USE语句。

   • DDL语句中直接引用Hologres数据服务信息。

     CREATE TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` (
       ...
     ) WITH (
       'connector' = 'hologres'
     );

   • DDL语句中设置物理表属性。

     CREATE TABLE `${catalog_name}`.`${db_name}`.`${schema_name.table_name}` (
       ...
     ) WITH (
       'connector' = 'hologres',
       'table_property.orientation' = 'column',
       'table_property.distribution_key' = 'a',
       'table_property.clustering_key' = 'b:desc',
       'table_property.bitmap_columns' = 'a,b',
       'table_property.segment_key' = 'c',
       'table_property.time_to_live_in_seconds' = '86400',
       'table_property.binlog.level' = 'replica',
       'table_property.binlog.ttl' = '86400'
     );

     说明

     • 在已注册的Hologres数据服务下创建表时，WITH参数中connector为必填参数，且取值为hologres。可省略endpoint等其他参数。

     • 在创建Hologres表时，在WITH参数中指定的物理表属性参数，部分属性无法修改。

     • Flink计算引擎VVR-6.0.3-Flink-1.15以下版本创建Hologres表时，在WITH参数中指定的物理表属性参数仅在首次建表时有效，不允许修改。如果您需要修改，则请到Hologres侧修改。Flink计算引擎VVR-6.0.3-Flink-1.15及以上版本支持修改Hologres物理表属性。

     • 目前不支持直接在Hologres表中添加或修改支持的WITH参数。对于这些参数，您可以通过SQL hints的方式在INSERT语句中添加或修改。

     • Flink计算引擎VVR-6.0.5-Flink-1.15及以上版本支持建表时设置列描述，对应的Hologres物理表也会继承相应的列描述。

2. 选中建表语句，单击左侧代码行数上的运行。

   

UI方式

1. 进入元数据管理页面。

   1. 登录实时计算控制台。

   2. 在Flink全托管页签，单击目标工作空间操作列下的控制台。

   3. 单击元数据管理。

2. 在Catalog列表页面，单击目标Catalog名称对应操作列下的删除。

3. 在弹出的对话框中，单击删除。

   说明

   删除完成后，在左侧元数据区域下即可查看目标Catalog已删除。

SQL命令方式

1. 在查询脚本文本编辑区域，输入以下命令。

   DROP CATALOG ${catalog_name}

   其中，catalog_name为您要删除的在Flink全托管开发控制台上显示的Hologres Catalog名称。

   警告

   删除Hologres Catalog不会影响已运行的作业，但对未上线或者作业需要暂停恢复的作业均产生影响，请您谨慎操作。

2. 选中删除Catalog的命令，鼠标右键选择运行。

3. 在左侧元数据区域，查看目标Catalog是否已删除。