Início / coding / Perguntas / 77442636
Accepted
Surender Raja
Asked: 2023-11-08 11:13:04 +0800 CST

consulta pyspark na instrução case gera erro

  • 772

Estou executando a consulta pyspark abaixo

Isso gera o erro abaixo. Quero que valores dinâmicos passem por meio de um varaibale para a instrução 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()

Eu recebo o erro abaixo

  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]

Não entendo qual é o problema com esta consulta. Alguém pode me ajudar, por favor

pyspark

1 respostas

  1. Best Answer

    Valores de texto simples precisam ser citados.

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

relate perguntas