TypeError:'DataFrame'วัตถุไม่รองรับรายการงานเมื่อใช้ดิวิชั่น

Question 1

Dividing สองคนจำนวนเต็มคอลัมน์ใน pyspark dataframe และได้รับข้อผิดพลาดนี้ด้วย มีความคิดอะไรอีกไหม

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

แค่เล็กน้อ 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

แค่เล็กน้อ 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)

ขอบคุณ Karthik และเก่งมากเข้าไปกับงานใหม่คอลัมน์ใน withColumn()นี้ทำงานอผ้าที่งดงาม.
คำอธิษฐานที่ดีที่สุดเกร็ก!!

TypeError:'DataFrame'วัตถุไม่รองรับรายการงานเมื่อใช้ดิวิชั่น

คำถาม

คำตอบที่ดีที่สุด

ในภาษาอื่นๆ

หน้านี้อยู่ในภาษาอื่นๆ

ดังอยู่ในนี้หมวดหมู่

ดังคำถามอยู่ในนี้หมวดหมู่