“一个简单的基于多处理的MapReduce框架”
mapreduce-p的Python项目详细描述
基于多处理的单主机mapreduce框架
这是一个简单的mapreduce框架。
示例程序
frommapreduceimport*frommathimportceil,sqrtdefmapper_2(item):return(item+5)*23-1defreducer_2(accumulated,item):returnaccumulated+itemdefis_prime(n):foriinrange(2,ceil(sqrt(n))):ifn%i==0:returnFalsereturnTrueif__name__=="__main__":N=150000print('* map & reduce ')mr=MapReducer().prefilter(is_prime).mapper(mapper_2).reducer(reducer_2,0)result=mr(range(N))print(' MR Result :',result)n=sum([(n+5)*23-1forninrange(N)ifis_prime(n)])print(' Validation:',n)
历史记录
0.5.1
- 更新示例
- 优化进出口
0.5.0
- 工艺速度优化
0.1.0
- 首次发布
欢迎加入QQ群-->： 979659372
