计算人口平均年龄

时间：2018-08-14 14:49:52 阅读：192 评论：0 收藏：0 [点我收藏+]

标签：usr pen ISE 函数 from tput normal imp image

创建实验数据:
from pyspark import SparkContext
import random
OutputFile = "file:///usr/local/spark/mycode/exercise/people"
sc = SparkContext(‘local‘,‘createPeopleAgeData‘)
peopleAge = []
for i in range(1,1001):
 rand = random.randint(1,100)
 peopleAge.append(str(i)+" "+str(rand))
RDD = sc.parallelize(peopleAge)
RDD.saveAsTextFile(OutputFile)
 

from pyspark import SparkContext
#配置sc
sc = SparkContext(‘local‘,‘CountAverAge‘)
#创建RDD 读入数据
RDD = sc.textFile("file:///usr/local/spark/mycode/exercise/peopleAge.txt")
#得到数据总条数
Count =RDD.count()
#对数据进行切割，只取年龄部分，然后把年龄字符串转成Int，然后用reduce函数累加
Average = RDD.map(lambda line : line.split(" ")[1]).map(lambda a: int(a)).reduce(lambda a,b :(a+b))
 
print(Count)
print(Average)
print("平均年龄为:{0}".format(Average / Count))
 

计算人口平均年龄

标签：usr pen ISE 函数 from tput normal imp image

原文地址：https://www.cnblogs.com/SoftwareBuilding/p/9473533.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行