文档

管理自定义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文件。

    说明

    在使用其他服务的HTTP路径时,需要该服务和Flink工作空间在同一VPC下,或者先打通Flink工作空间和目标服务的公网网络后,使用公网地址访问,详情请参见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图标,单击确定

相关文档