pyspark - 用于否定列的 Pyspark 函数

Question

是否有一个内置函数可以添加一个新列，它是原始列的否定？

Spark SQL 有这个功能negative()。Pyspark 似乎没有继承这个功能。

df_new = df.withColumn(negative("orginal"))

标签： pysparkaddnegate

Answer 1

假设您的列original是 boolean ：

df_new = df.withColumn(~df["original"])  # Equivalent to "not original"