我有3个数据框'u','join5'和站点。
这是数据框'u'的架构。
scala> println(u.printSchema)
root
|-- split_sk: integer (nullable = true)
|-- new_date: string (nullable = true)
现在使用联接“ join5”和“ site”数据帧创建join6。这是我的2个问题-
-
以下查询中的“ u(“ split_sk”)'是什么?在查询中未明确给出与'u'的联接时,是否可以使用数据框'u'的列进行随机比较?
-
在Scala中,尤其是在以下查询中,()符号表示什么?
val join6 = join5.join(site,u("split_sk") <=> site("split_key") &&($"new_date" >= $"effective_dt") && ($"new_date" <= $"expiry_dt"),"left")