创建EMR Trino节点

使用限制

• 仅支持使用Serverless资源组运行该类型任务。

• DataLake或自定义集群若要在DataWorks管理元数据，需先在集群侧配置EMR-HOOK。若未配置，则无法在DataWorks中实时展示元数据、生成审计日志、展示血缘关系、开展EMR相关治理任务。配置EMR-HOOK，详情请参见配置Hive的EMR-HOOK。

• Trino开启了LDAP认证的情况下，需要登录EMR所在Master机器，下载/etc/taihao-apps/trino-conf目录中的keystore文件。登录DataWorks控制台，单击进入左侧导航栏的更多 > 管理中心，在下拉框中选择对应工作空间后单击进入管理中心，在左侧导航栏单击集群管理，找到已注册的目标EMR集群，切换至账号映射页签，单击编辑账号映射按钮，进入编辑页面，单击上传keystore文件按钮上传该文件。

（可选）选择EMR集群实例

若您的工作空间注册了多个EMR集群，则可在节点编辑页面顶部选择合适的集群。若仅注册了一个EMR集群，默认使用该集群进行开发操作。

连接器配置

• 查询MySQL相关表之前需要完成EMR Trino内置连接器配置，详情请参见MySQL连接器配置。

• 查询Hive相关表之前需要完成EMR Trino内置连接器配置，详情请参见Hive连接器配置。

• 查询其他数据源相关表数据，内置连接器配置可参见配置连接器。

编辑SQL代码

在SQL编辑区域输入任务代码，示例如下。

-- 使用方法
-- SELECT * FROM <catalog>.<schema>.<table>;
-- 参数说明
-- <catalog>为要连接的数据源的名称。
-- <schema>为要使用的数据库的名称。
-- <table>为待查询的数据表。
-- 例如，如果要查看Hive数据源中默认数据库中的hive_table表的数据
-- 查Hive表
SELECT * FROM hive.default.hive_table;

-- 例如，如果要查看MySQL数据源中自建数据库rt_data库中的rt_user表的数据 
-- 查MySQL表  
SELECT * FROM mysql.rt_data.rt_user;

-- 联查Hive和MySQL表
SELECT DISTINCT a.id, a.name,b.rt_name FROM hive.default.hive_table a INNER JOIN mysql.rt_data.rt_user b ON a.id = b.id;

-- 查Hive表，可以结合调度参数使用
SELECT * FROM hive.default.${table_name};

执行SQL任务

1. 在工具栏单击图标，在参数对话框选择已创建的调度资源组，单击运行。

   说明

   • 访问公共网络或VPC网络环境的数据源需要使用与数据源测试连通性成功的调度资源组。详情请参见网络连通方案。

   • 如果您后续执行任务需要修改使用的资源组，您可单击带参运行图标，选择需要更换的调度资源组。

   • 使用EMR Trino节点查询数据时，返回的查询结果最大支持10000条数据，并且数据总量不能超过10M。

2. 单击图标，保存编写的SQL语句。

（可选）配置高级参数

如您需要调整SQL语句执行方式，可点击右侧导航栏的高级设置进行相应设置。