首页/数据/数仓建模速查/Trino:联邦查询与数据源连接
湖仓与引擎63 条

Trino:联邦查询与数据源连接

Trino 通过 Connector 连接 Hive、Iceberg、MySQL、Kafka 等多源做联邦查询,适合跨源探索与即席分析;结果直接拉取时要注意内存限制。

数仓建模速查数据更新于 2026-10-12
定位联邦查询引擎
连接Connector 体系
场景跨源即席分析
限制大结果集易 OOM

跨源查询

跨源查询
SELECT h.store_id, m.store_name, sum(h.pay_amt) AS pay_amt
FROM hive.dw.dwd_trade_order_hive h
JOIN mysql.dw.dim_store m ON h.store_id = m.store_id
WHERE h.dt = DATE '2026-10-12'
GROUP BY h.store_id, m.store_name;
跨源 join 会把数据拉到 Trino 侧处理,数据量大时先在各源内过滤。

易错点

  • 跨源大表直接 join,worker 内存溢出

数据来源与参考

  • Trino 官方文档:Overview
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌