【发布时间】:2023-03-03 23:43:01
【问题描述】:
我正在尝试将字符串常量添加为 pyspark 中的新列。我正在使用 2.4.4 版本的火花。 我正在使用这个
data.withColumn("currentdate", lit(constant_name))
我收到错误“未解析的引用已点亮”。似乎 2.4.4 中没有因错误而点亮的功能,但当我看到文档时,它就在那里。
【问题讨论】:
-
你导入spark函数了吗?
-
是的,我已经使用这个“ from pyspark.sql.functions import *”导入了spark函数
-
试试这个 - from pyspark.sql.functions import F & use F.lit(constant_name)
-
我想你想说试试这个,“import pyspark.sql.functions as F”,它对我有用,谢谢
-
是的,对错字很抱歉.. :)
标签: apache-spark pyspark apache-spark-sql pyspark-dataframes