如何提取列值以与sparkDataframe中的rlike进行比较

cyvaqqii  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(508)

我在spark 2.3中有下面的代码。它显示了错误,因为rlike只能计算字符串而不能计算列字段,所以我想将相应col(unique\u handle\u regex)列中的值提取为string

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

ao218c7q1#

试试下面的代码。

val whereExpr = Seq("unique_handle","unique_handle_regex").mkString(" rlike ")
val df3 = df1.join(df2).select("*").where(whereExpr)

相关问题