管理自定义Catalog

如果内置的Catalog类型无法满足您的业务需求,您可以使用自定义Catalog类型。本文为您介绍如何配置自定义Catalog。

注意事项

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

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

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

创建并使用自定义Catalog

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

    1. 登录实时计算控制台

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

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

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

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

    image

    方式

    说明

    上传文件

    单击选择文件,选择您的目标自定义Catalog类型文件。自定义Catalog类型开发详情请参见Catalogs

    外部URL

    填写外部URL信息。当需要使用其他服务上存在的JAR文件时,可以使用外部URL功能获取JAR文件。

    说明

    仅支持以下两类外部URL:

    • 开通Flink工作空间时选择的OSS Bucket地址。您可以在实时计算管理控制台目标工作空间详情中查看绑定的OSS Bucket。

    • 实时计算Flink版可以访问且被允许访问(公共读或被授予权限)的其他外部存储系统地址。

  4. 单击下一步

  5. 确认Properties信息后,单击确定

    image

  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类型名称右侧的image图标,单击确定

相关文档