使用XIHE BSP SQL进行作业开发

本文介绍如何使用XIHE BSP SQL进行外表作业开发。

前提条件

示例数据说明

本文示例将数据文件xihe_oss.txt上传至OSS路径oss://adb-test-1/test_xihe/中,数据行分隔符为换行符,列分隔符为英文逗号(,)。示例数据文件内容如下:

001,Anna,99,London
002,Bob,67,USA
003,Cindy,78,Spain
004,Dan,100,China

步骤一:创建OSS外表

  1. 登录云原生数据仓库AnalyticDB MySQL控制台,在左上角选择集群所在地域。在左侧导航栏,单击集群列表,在企业版湖仓版页签下,单击目标集群ID。

  2. 在左侧导航栏,单击作业开发 > SQL开发

  3. SQLConsole窗口,选择Job型资源组和XIHE引擎。

  4. 输入以下语句,并单击执行SQL(F8),创建外库xihe_external_db

    CREATE EXTERNAL DATABASE xihe_external_db;
  5. 输入以下语句,并单击执行SQL(F8),创建外表xihe_oss_table

    CREATE EXTERNAL TABLE xihe_external_db.xihe_oss_table
    (
     id int ,
     name string ,
     score int,
     city string
    )
    ROW FORMAT DELIMITED FIELDS TERMINATED BY  ','
    STORED AS TEXTFILE
    LOCATION 'oss://adb-test-1/test_xihe/xihe_oss.txt';

步骤二:查询OSS外表

输入以下语句,并单击执行SQL(F8),查询外表xihe_oss_table数据。

SELECT * FROM xihe_external_db.xihe_oss_table;
说明

如果湖仓版集群中有计算预留资源,企业版集群中有预留资源,可以使用XIHE MPP SQL在线方式(即选择XIHE引擎和Interactive资源组)查询外表数据。