TypeError: 'DataFrame' objet ne prend pas en charge l'élément de cession lors de l'utilisation de la division

Question 1

TypeError: 'DataFrame' objet ne prend pas en charge l'élément de cession lors de l'utilisation de la division.

La division de deux colonnes de type entier dans un pyspark dataframe et la réception de cette erreur. Des idées?

Reproductible:

simpleData = (((1, 2), (2, 6), (3, 6))
columns= ["sales","users"]
df = spark.createDataFrame(data = simpleData, schema = columns)
df = df.withColumn("users", df["users"].cast(IntegerType()))
df = df.withColumn("sales", df["sales"].cast(IntegerType()))
df['buy_rate'] = df['sales']/ df['users']

Question 2

juste un petit tweak .

from pyspark.sql.types import IntegerType
import pyspark.sql.functions as F
simpleData=((1, 2), (2, 6), (3, 6))
columns= ["sales","users"]
df = spark.createDataFrame(data = simpleData, schema = columns)
df = df.withColumn("users", df["users"].cast(IntegerType()))
df = df.withColumn("sales", df["sales"].cast(IntegerType()))

df1 = df\
    .withColumn("buy_rate", (F.col("sales") / F.col("users")))
display(df1)

Karthikeyan Rasipalay Durairaj · Answer 1 · 2021-11-23T20:01:03

juste un petit tweak .

from pyspark.sql.types import IntegerType
import pyspark.sql.functions as F
simpleData=((1, 2), (2, 6), (3, 6))
columns= ["sales","users"]
df = spark.createDataFrame(data = simpleData, schema = columns)
df = df.withColumn("users", df["users"].cast(IntegerType()))
df = df.withColumn("sales", df["sales"].cast(IntegerType()))

df1 = df\
    .withColumn("buy_rate", (F.col("sales") / F.col("users")))
display(df1)

Grâce Karthik, et une très bonne approche avec la cession de la nouvelle colonne dans la withColumn() cela a fonctionné à merveille.

TypeError: 'DataFrame' objet ne prend pas en charge l'élément de cession lors de l'utilisation de la division

La question

La meilleure réponse

Dans d'autres langues

Cette page est dans d'autres langues

Populaires dans cette catégorie

Questions populaires dans cette catégorie