在 Scala 中使用 Spark 时,火花selectExpr.html
https://docs.databricks.com/spark/latest/sparkr/functions/selectExpr.html 叫什么名字?
编辑
如何在withColumn
语句中使用它?
val scalarInput = 123
df.withColumn("foo", selectExpr("""someHiveUDF( ${scalarInput}, column)"""))
失败与 selectExpr
未找到
名称完全相同,selectExpr
:
def selectExpr(exprs: String*): DataFrame
org.apache.spark.sql.functions._
的expr
就是你想要的!