pyspark查询case语句抛出错误

2guxujil 于 2023-11-16 发布在 Spark

关注(0)|答案(1)|浏览(106)

我正在运行下面的pyspark查询
它抛出下面的错误。我希望动态值通过一个变量传入case语句

data1 = 'HI'
 data2 = 'HELLO'

 spark.sql(f""" select  Initials,
                case when Initials  in ('AM','NJ') then {data1} else {data2} end as s  
                from omegawriter""").display()

字符串
我得到下面的错误

A column or function parameter with name `HI` cannot be resolved.
  Project [Initials#69, CASE WHEN Initials#69 IN (AM,NJ) THEN 'HI ELSE 'HELLO END AS s#57]

型
我不明白这个查询有什么问题。有人能帮助我吗

pyspark

来源：https://stackoverflow.com/questions/77442636/pyspark-query-on-case-statement-throws-error

1条答案

按热度按时间

luaexgnf1#

纯文本值需要加引号。

spark.sql(f""" select  Initials,
                case when Initials  in ('AM','NJ') then '{data1}' else '{data2}' end as s  
                from omegawriter""").display()

字符串

赞(0）回复(0）举报 2023-11-16

我来回答

pyspark查询case语句抛出错误

1条答案

相关问题

热门标签

最新问答