TypeError: 'DataFrame' el objeto no admite elemento de asignación cuando se utiliza la división de

Question 1

TypeError: 'DataFrame' el objeto no admite elemento de asignación cuando el uso de la división.

Que divide en dos las columnas de enteros en un pyspark dataframe y recibiendo este error. Alguna idea?

Reproducible:

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

sólo pequeños retoques .

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

sólo pequeños retoques .

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)

Gracias Karthik, y muy buen enfoque con la asignación para la nueva columna dentro de la withColumn() este funcionaba a la perfección.

TypeError: 'DataFrame' el objeto no admite elemento de asignación cuando se utiliza la división de

Pregunta

Mejor respuesta

En otros idiomas

Esta página está en otros idiomas

Popular en esta categoría

Las preguntas más habituales en esta categoría