TypeError:'데이터 프레임'객체 지원하지 않는 항목을 할당할 때 사용하는 사단.
을 나누는 두 개의 정수 열 pyspark 데이터 프레임과 이 오류가 있습니다. 어떤 아이디어가?
재현성:
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']
그냥 작은 조정할 필요가 있다.
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)
