小编sap*_*tak的帖子

如何从Spark Dataframe中的Row对象获取值?

对于

averageCount = (wordCountsDF
                .groupBy().mean()).head()
Run Code Online (Sandbox Code Playgroud)

我明白了

行(AVG(计数)= 1.6666666666666667)

但是当我尝试:

averageCount = (wordCountsDF
                .groupBy().mean()).head().getFloat(0)
Run Code Online (Sandbox Code Playgroud)

我收到以下错误:

AttributeError:getFloat ----------------------------------------------- ---------------------------- AttributeError Traceback(最近一次调用last)in()1#TODO:用适当的代码替换--- - > 2 averageCount =(wordCountsDF 3 .groupBy().mean()).head().getFloat(0)4 5 print averageCount

getattr中的 /databricks/spark/python/pyspark/sql/types.py(self,item)1270 引发AttributeError(item)1271
除了ValueError: - > 1272 raise AttributeError(item)1273 1274 def setattr(self,key,value) :

AttributeError:getFloat

我究竟做错了什么?

apache-spark pyspark spark-dataframe

16
推荐指数
3
解决办法
3万
查看次数

标签 统计

apache-spark ×1

pyspark ×1

spark-dataframe ×1