管理自定义Catalog
如果Flink全托管中内置的Catalog无法满足您的业务需求,您可以使用自定义Catalog。本文为您介绍如何管理自定义Catalog,包括创建自定义Catalog类型、查看自定义Catalog和删除自定义Catalog。
注意事项
Catalog类型需要唯一,如果自定义Catalog的名称和后续Flink全托管中内置的名称相同,则优先使用您的自定义Catalog。
删除自定义Catalog类型后,该自定义Catalog类型下注册的Catalog实例也将被删除。
进入自定义Catalog管理入口
登录实时计算控制台。
在Flink全托管页签,单击目标工作空间操作列下的控制台。
在左侧导航栏,单击元数据管理。
创建自定义Catalog类型
按照进入自定义Catalog管理入口操作步骤,进入到自定义Catalog管理入口。
单击创建Catalog。
在自定义Catalog页签,单击创建自定义Catalog类型。
在创建自定义Catalog类型对话框,配置自定义Catalog信息。
方式
说明
上传文件
在注册JAR区域,单击上传文件,然后在上传文件右侧,单击选择文件,选择您的目标自定义Catalog文件。
重要自定义Catalog开发详情请参见Catalogs。
自定义Catalog JAR文件不能大于200 MB。如果超过200 MB,建议使用外部URL方式进行。
外部URL
在注册JAR区域,单击外部URL,填写外部URL信息。当您JAR文件超过200MB或者需要使用其他服务上存在的JAR文件时,可以使用外部URL功能获取JAR文件。
重要如果JAR文件超过200MB,可以选择将自定义Catalog文件放在实时计算Flink全托管绑定的OSS Bucket的sql-artifacts/namespaces/{namespace}目录下,再使用该文件的HTTPS路径即可。
支持使用其他服务的HTTP路径,需要该服务和实时计算Flink全托管在同一VPC下或者先打通实时计算Flink全托管和目标服务的公网网络链接后使用公网地址。详情请参见Flink全托管集群如何访问公网?
单击下一步。
确认Properties信息。
单击确定。
创建自定义Catlog实例
在创建完自定义Catalog类型后,您就可以直接创建自定义Catalog实例了。具体的步骤如下:
在Catalog列表页面,单击创建Catalog。
在自定义Catalog页签,单击您刚创建好的自定义Catalog类型名称后,单击下一步。
填写Catalog代码信息及参数值后,单击确定。
代码示例如下。
CREATE CATALOG `CatalogName` WITH ( 'type' = 'hologres-custom', 'endpoint' = 'yourEndpoint', 'username' = 'yourUsername', 'password' = 'yourPassord', 'dbname' = 'yourDbname' );
创建Catalog实例时,Catalog实例名称、类型和required字段为必填的,需要按照您实际情况进行修改。
说明Catalog实例名称需要添加反引号(``),否则可能运行会报错。
在左侧元数据列表中,查看自定义Catalog实例是否已创建好。
查看自定义Catalog类型
单击创建Catalog。
在自定义Catalog页签,鼠标悬浮在自定义Catalog类型名称上面,查看自定义Catalog JAR包路径、Catalog类型、创建时间和创建人等信息。
删除自定义Catalog类型
单击创建Catalog。
在自定义Catalog页签,单击目标自定义Catalog名称右侧的
图标。
单击确定。