小编A. *_* R.的帖子

将数组传递给Python Spark Lit函数

假设我有一个包含数字1-10的numpy数组a.所以a是[1 2 3 4 5 6 7 8 9 10].

现在,我还有一个Python Spark数据帧,我想要添加我的numpy数组a.我认为一列文字将完成这项工作.所以我做了以下事情:

df = df.withColumn("NewColumn", F.lit(a))
Run Code Online (Sandbox Code Playgroud)

这不起作用.错误是"不支持的文字类型类java.util.ArrayList".

现在,如果我只尝试数组中的一个元素,如下所示,它可以工作.

df = df.withColumn("NewColumn", F.lit(a[0]))
Run Code Online (Sandbox Code Playgroud)

有没有办法可以做我正在尝试的事情?我一直在努力完成我想完成的任务,这是我最接近完成它的任务.我查看了所有相关的Stack Overflow问题,但我没有得到我想要的答案.任何帮助表示赞赏.谢谢.

python literals apache-spark pyspark pyspark-sql

14
推荐指数
1
解决办法
5818
查看次数

标签 统计

apache-spark ×1

literals ×1

pyspark ×1

pyspark-sql ×1

python ×1