在 Spark SQL 中,在 SQL 查询中使用用户定义函数 (UDF) 可能会引入意外行为,尤其是笛卡尔积的出现,而不是预期的完全外连接。
当使用 UDF 时,Spark 将它们视为任意函数,考虑每种可能的参数组合进行评估。这就需要笛卡尔积来确保对所有对进行彻底检查。
与 UDF 不同,像 t1.foo = t2.bar 这样的基本相等比较具有可预测的行为,从而允许 Spark根据相等标准有效地打乱 t1 和 t2 行。由于 UDF 的不可预测性,这种优化不存在。
在关系代数中,外连接基本上表示为自然连接,它只是一个流行 SQL 引擎的优化。因此,重要的是要认识到,在不改变 Spark SQL 引擎本身的情况下,通过 UDF 强制对笛卡尔积进行外连接并不容易实现。
以上是Spark SQL 中的 UDF:为什么有时会创建笛卡尔积而不是完全外连接?的详细内容。更多信息请关注PHP中文网其他相关文章!