小编Utk*_*ahu的帖子

PySpark - 从另一列传递一个值作为 spark 函数的参数

我有一个 spark 数据框,它看起来像这样,其中 expr 是 SQL/Hive 过滤器表达式。

+-----------------------------------------+
|expr                     |var1     |var2 |
+-------------------------+---------+-----+
|var1 > 7                 |9        |0    |
|var1 > 7                 |9        |0    |
|var1 > 7                 |9        |0    |
|var1 > 7                 |9        |0    |
|var1 = 3 AND var2 >= 0   |9        |0    |
|var1 = 3 AND var2 >= 0   |9        |0    |
|var1 = 3 AND var2 >= 0   |9        |0    |
|var1 = 3 AND var2 >= 0   |9        |0    |
|var1 = 2 …
Run Code Online (Sandbox Code Playgroud)

apache-spark apache-spark-sql pyspark

6
推荐指数
1
解决办法
1940
查看次数

标签 统计

apache-spark ×1

apache-spark-sql ×1

pyspark ×1