如何在Pyspark Dataframe中针对特定行中的特定列?

2024-10-01 07:11:13 发布

您现在位置:Python中文网/ 问答频道 /正文

如何传递“vin等于1 idx”以更新列的值

+----------+---------+---+
|       vin|    vinar|idx|
+----------+---------+---+
|  wdwer43w| eqr21144|  1|
|Ebntyure43|Evirter45|  2|
+----------+---------+---+
cur='06City'

df4=df4.withColumn('vin',F.when(F.col('vin')==F.col('idx[1]'),cur).otherwise(F.col('vin')))

Tags: colwhencuridxvinwithcolumndf4otherwise
1条回答
网友
1楼 · 发布于 2024-10-01 07:11:13

条件应为索引等于1,而不是vin:

df4 = df4.withColumn('vin', F.when(F.col('idx') == 1, cur).otherwise(F.col('vin')))

相关问题 更多 >