我嘗試在 pyspark 中執行此查詢,但始終出現錯誤。我到處找,但我不知道,或者如果有人可以幫助我,它就不起作用。此請求的目標是更新我稍后將創建的名為 temp_ok 的新列:這是我的代碼:
CASE WHEN _temp_ok_calculer='non' AND Operator level 2 ="XXX" OR Operator level 2= "AAA" AND Auto Cleaning criteria !="YYY" Auto Cleaning criteria <> "AA" AND Workstation Type = "Chaine A" THEN 'ok' ELSE CASE WHEN _temp_ok_calculer='ok' THEN 'ok' ELSE 'ko' END END
我的表包含此列:_temp_ok_calculer、操作員級別 2、自動清潔標準、作業站型別
uj5u.com熱心網友回復:
Spark SQL 使用反引號` 作為分隔符,其中有空格的識別符號必須是SQL 中的分隔識別符號。所以
CASE WHEN _temp_ok_calculer='non' AND `Operator level 2` ="XXX" OR . . .
轉載請註明出處,本文鏈接:https://www.uj5u.com/yidong/400123.html
