map( key: [url, pagerank], value: outlink_list )
for each outlink in outlink_list
emit( key: outlink, value: pagerank/size(outlink_list) )
emit( key: url, value: outlink_list )
reducer( key: url, value: list_pr_or_urls )
outlink_list = []
pagerank = 0
for each pr_or_urls in list_pr_or_urls
if is_list( pr_or_urls )
outlink_list = pr_or_urls
else
pagerank += pr_or_urls
pagerank = 1 - DAMPING_FACTOR + ( DAMPING_FACTOR * pagerank )
emit( key: [url, pagerank], value: outlink_list )
相关文章
- FPGA Asynchronous FIFO设计思路(2)
- 出现这个错误Uncaught ReferenceError: $ is not defined该如何解决思路
- Hadoop MapReduce概念学习系列之mr程序详谈(二十三)
- 2025五一杯数学建模竞赛思路助攻预定-一、概况
- 大数据:Hadoop(HDFS 的设计思路、设计目标、架构、副本机制、副本存放策略)
- 腾讯云大数据套件Hermes-MR索引插件使用总结
- openstack镜像制作思路、指导及问题总结
- Vue中resetFields方法清空无法其作用(element-ui)解决思路
- Ubuntu开启自启动PostgreSQL读取HDD失败处理思路-解决思路:
- ArcGIS Pro开发Web3D应用(2)——地图分屏对比(多屏对比)思路