PySpark: сделать столбец положительных чисел отрицательным

Question

Довольно просто.У меня есть фрейм данных PySpark со столбцом положительных чисел, которые я хотел бы сделать отрицательным.Как я могу это сделать?

Answer 1

Вы можете использовать атрибут df.withColumn. Чтобы изменить имя столбца на «оригинальный»

df = df.withColumn('flipped', - df['orginal'])

Это добавляет новый столбец под именем, отображаемым с нужным результатом.Чтобы просто изменить знак в названии этого столбца, вы можете сделать

df = df.withColumn('original', - df['orginal'])

http://spark.apache.org/docs/2.1.0/api/python/pyspark.sql.html