scala – 使用变量过滤Spark Dataframe

发布时间：2020-12-16 18:39:54 所属栏目：安全来源：网络整理

导读：这在火花数据帧中是否可行(1.6 / 2.1) val data="some variable"df.filter("column1" data) 我可以使用静态值执行此操作,但无法弄清楚如何通过变量进行过滤. 解决方法 import org.apache.spark.sql.functions._val data="some variable"df.filter(col("colum

这在火花数据帧中是否可行(1.6 / 2.1)

val data="some variable"

df.filter("column1"> data)

我可以使用静态值执行此操作,但无法弄清楚如何通过变量进行过滤.

解决方法

import org.apache.spark.sql.functions._

val data="some variable"
df.filter(col("column1") > lit(data))

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!