管理MaxCompute Catalog

背景信息

使用限制

• 仅Flink计算引擎VVR 6.0.7及以上版本支持配置MaxCompute Catalog。

• MaxCompute Catalog不支持创建数据库，即MaxCompute中的项目。

• MaxCompute Catalog不支持修改表结构。

• MaxCompute Catalog不支持CREATE TABLE AS（CTAS）语句。

创建MaxCompute Catalog

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

   CREATE CATALOG `<catalogName>` WITH (
     'type' = 'odps',
     'endpoint' = '<odpsEndpoint>',
     'accessId' = '<aliyunAccountAccessId>',
     'accessKey' = '<aliyunAccountAccessKey>',
     'project' = '<defaultProject>',
     'userAccount' = '<RAMUserAccount>'
   );

   参数	说明	类型	是否必填	备注
   catalogName	MaxCompute Catalog的名称。	String	是	请填写为自定义的英文名。
   type	Catalog类型。	String	是	固定值为odps。
   endpoint	MaxCompute服务连接站点。	String	是	具体站点请参见Endpoint。
   accessId	访问MaxCompute服务所使用阿里云账号的AccessKey ID。	String	是	该账号需要对Catalog访问的项目有admin权限。
   accessKey	访问MaxCompute服务所使用阿里云账号的AccessKey Secret。	String	是	无。
   project	Catalog中作为默认数据库的MaxCompute项目名。	String	否	若不设置该值，默认项目为default。
   userAccount	阿里云账号或RAM用户名称。	String	否	若使用的AccessKey非主账号，仅对主账号下的部分项目有admin权限，则需要设置该参数为账号名称，例如RAM$[<account_name>:]<RAM_name>，MaxCompute Catalog将仅展示该账号有权限的项目列表。 MaxCompute用户权限管理参见用户规划与管理。

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

   您也可以光标放在创建Catalog的代码上，右键单击运行。

3. 在左侧元数据区域，查看创建的Catalog。

查看MaxCompute Catalog

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

   DESCRIBE `<catalogName>`.`<projectName>`.`<tableName>`;

   参数	说明
   catalogName	MaxCompute Catalog名称。
   projectName	MaxCompute中的项目名。
   tableName	MaxCompute中存储的物理表名。

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

   运行成功后，可以在编辑区域下方的结果一栏中看到MaxCompute物理表在Flink中对应的Schema信息。

删除MaxCompute Catalog

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

   DROP CATALOG `<catalogName>`;

   其中<catalogName>为您要删除的目标MaxCompute Catalog名称。

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

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

MaxCompute与Flink的类型映射

MaxCompute支持的类型参见2.0数据类型版本。