实时计算Flink版：管理自定义Catalog

注意事项

• 自定义Catalog类型间的名称需要唯一。

  当自定义Catalog类型的名称与内置的名称相同时，优先使用您的自定义Catalog。

• 删除自定义Catalog类型后，该自定义Catalog类型下注册的Catalog也将被删除。

创建并使用自定义Catalog

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

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

   2. 单击目标工作空间操作列下的控制台。

   3. 在左侧导航栏，单击元数据管理。

2. 单击创建Catalog，在自定义Catalog页签，单击创建自定义Catalog类型。

3. 在创建自定义Catalog类型对话框，配置自定义Catalog类型信息。

   

   方式	说明
   上传文件	单击选择文件，选择您的目标自定义Catalog类型文件。自定义Catalog类型开发详情请参见Catalogs。
   外部URL	填写外部URL信息。当需要使用其他服务上存在的JAR文件时，可以使用外部URL功能获取JAR文件。 说明 仅支持以下两类外部URL： 开通Flink工作空间时选择的OSS Bucket地址。您可以在实时计算管理控制台目标工作空间详情中查看绑定的OSS Bucket。 实时计算Flink版可以访问且被允许访问（公共读或被授予权限）的其他外部存储系统地址。

4. 单击下一步。

5. 确认Properties信息后，单击确定。

   

6. 在自定义Catalog页签，单击您刚创建好的自定义Catalog类型名称，单击下一步。

7. 填写Catalog代码信息及参数值后，单击确定，创建Catalog。

   代码示例如下，您可以根据实际情况进行修改。

   CREATE CATALOG `catalogname` --catalogname为创建的Catalog名称。
   WITH (
   'type' = 'hologres-custom',  --步骤5中的Catalog类型名称。
   'endpoint' = 'yourEndpoint',  --步骤5中required勾选的参数为必填WITH参数，下同。
   'username' = 'yourUsername',
   'password' = 'yourPassword',
   'dbname' = 'yourDbname'
   );

   说明

   Catalog名称建议添加反引号（``），否则当名称中包含.等字符时运行会报错。

查看或删除自定义Catalog类型

1. 在元数据管理页面，单击创建Catalog。

2. 单击自定义Catalog页签，查看或删除自定义Catalog类型。

   • 查看：鼠标悬浮在自定义Catalog类型名称上面，查看自定义Catalog类型JAR包路径、Catalog类型、创建时间和创建人等信息。

   • 删除：单击目标自定义Catalog类型名称右侧的图标，单击确定。

相关文档

• Flink内置了多种Catalog类型，详情请参见管理元数据。

• 支持的连接器，详情请参见支持的连接器。