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