我在 Databricks 中使用 Spark 2.1 版。我有一个名为 wamp 的数据框我想向其中添加一个名为 region 的列应该采用常数值 NE .但是，我收到一条错误消息 NameError: name 'lit' is not defined当我运行以下命令时:
wamp = wamp.withColumn('region', lit('NE'))
我究竟做错了什么？
最佳答案
您需要导入 lit
任何一个
from pyspark.sql.functions import *
将使
lit可用的或类似的东西
import pyspark.sql.functions as sf
wamp = wamp.withColumn('region', sf.lit('NE'))
关于apache-spark - 将常量值列添加到 Spark 数据框，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44033037/