我在spark 2.3中有下面的代码。它显示了错误,因为rlike只能计算字符串,而不能计算列字段。所以我想提取相应col(unique_handle_regex(列中的值作为字符串
val df3 = df1.join(df2).select("*").where(col(unique_handle) rlike col(unique_handle_regex))
请尝试以下代码。
val whereExpr = Seq("unique_handle","unique_handle_regex").mkString(" rlike ")
val df3 = df1.join(df2).select("*").where(whereExpr)