0

我在 spark 2.3 中有以下代码。它显示错误,因为 rlike 只能评估字符串而不是列字段,所以我想将相应 col(unique_handle_regex) 列中的值提取为字符串

val df3 = df1.join(df2).select("*").where(col(unique_handle) rlike col(unique_handle_regex))
4

1 回答 1

1

试试下面的代码。

val whereExpr = Seq("unique_handle","unique_handle_regex").mkString(" rlike ")
val df3 = df1.join(df2).select("*").where(whereExpr)
于 2020-07-08T16:32:49.187 回答