hadoop 计算减速器内的平均温度

xqnpmsa8  于 2022-12-03  发布在  Hadoop
关注(0)|答案(1)|浏览(194)

我正在尝试编写一个代码,根据ncdc天气计算平均温度(reducer.py)。
第一个

b4qexyjb

b4qexyjb1#

首先,您显示的数据没有制表符,所以不清楚为什么您显示了在制表符上拆分行并找到最大值的代码。
要求平均值,需要将所有看到的值收集到一个列表(values.append(int(val)))中,然后可以在循环结束时执行from statistics import mean并调用mean(values)
我强烈建议您使用mrjobpyspark

相关问题