from pyspark.sql.functions import regexp_replace,col newDF=newDF.withcolumn("Maxpulse",col("Maxpulse").cast(IntegerType())) AttributeError: 'DataFrame' object has no attribute 'withcolumn'
这里Maxpulse是列名，我试图将其数据类型更改为整数，但遇到了属性错误
sg3maiej1#
如果你的newDF是一个pandas dataframe，那么pandas没有withColumn，你会得到错误。如果你的newDF是一个spark dataframe，那么按照@Priyanka的评论执行withColumn（大写C）
newDF
withColumn
from pyspark.sql.functions import regexp_replace,col newDF=newDF.withColumn("Maxpulse",col("Maxpulse").cast(IntegerType()))
1条答案
按热度按时间sg3maiej1#
如果你的
newDF是一个pandas dataframe，那么pandas没有withColumn，你会得到错误。如果你的
newDF是一个spark dataframe，那么按照@Priyanka的评论执行withColumn（大写C）