开始使用免费开始使用

何时使用广播 join

既然您已经知道 shuffle 是瓶颈,您在 Global Retail Analytics 的团队想修复一条慢查询。它使用标准的左连接将 sales_transactions 表(5,000 万行)与 product_categories 表(2,000 行)进行 join,运行时间超过 10 分钟。您建议使用 F.broadcast() 切换为广播 join。

广播 join 为什么能加速这条查询?

本练习是课程的一部分

在 Databricks 中使用 Spark SQL 进行数据转换

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习