Surender Raja's questions

我正在运行下面的 pyspark 查询

它抛出以下错误。我希望动态值通过 varaibale 传递到 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]

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

 I dont know why this spark sql skips the last 3 000s after that decimal point

    df = spark.sql("""
      select cast('1900-01-01 00:00:00.000' as timestamp) as a  from dbo.products
      """)

  df.show(1,False)

上面的查询生成 1900-01-01 00:00:00 它以某种方式错过了小数点后的最后 3 个零

预计是

 1900-01-01 00:00:00.000

有人可以帮忙吗

如何拆分分隔字符串 TSQL 并通过循环（while 或 for）并根据拆分值更新表列

基本上 dbo.omega 需要根据 @source 的值更新latest_version 列

declare @source [varchar](500)
begin 
set @source = "employee:0,dept:1" # it is comma delimited string 

 #  I want to write logic for these two updates in a single update stament by looping through @source 
 #UPDATE dbo.omega set latest_version = 0 where obj_name = 'employee'
 #UPDATE dbo.omega set latest_version = 1 where obj_name = 'dept'

 splitarr = @source.split(",")
 i = 0
 while(i < len(splitarr)):
  UPDATE dbo.omega set latest_version = splitarr(i)
  i =i+1 
 end