TypeError: 'DataFrame' obiect nu are suport element de misiune atunci când se utilizează divizia

Question 1

TypeError: 'DataFrame' obiect nu are suport element de misiune atunci când se utilizează divizie.

Împărțirea doi întregi coloane dintr-o pyspark dataframe și primirea de această eroare. Orice idei?

Reproductibile:

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

doar mici 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

doar mici 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)

Multumesc Karthik, și foarte bună abordare cu tema nouă coloană în withColumn() aceasta a lucrat frumos.

TypeError: 'DataFrame' obiect nu are suport element de misiune atunci când se utilizează divizia

Problema

Cel mai bun răspuns

În alte limbi

Această pagină este în alte limbi

Popular în această categorie

Întrebări frecvente în această categorie