MapReduce python编程，你是用啥方法来统计特定单词出现次数的呢
谢邀！
使用MapReduce的streaming来调用python脚本处理每一行数据，比如单词的切割，python脚本将处理的结果通过streaming返回给java程序。然后在reducer聚合再调用你的python脚本实现每个词的累加。
■网友
蟹妖 @王权富贵
在wordcount前加个filter，过滤掉不属于“特定单词”的输入。
■网友
泻药，这不就是一个filter的事么？
Stream可以用proactive的方式，没有必要用map reduce
现在协程都烂大街了，直接用proactive的方式就好了，不需要用reactive
如果你只是想计算word count的话，直接抓个await来用，代码直观很多
■网友
【MapReduce python编程，你是用啥方法来统计特定单词出现次数的呢】 谢邀！首先做词频统计，词频统计的库很多，中文英文的都有，英文相对简单，中文比较复杂。然后再在结果中筛选。
■网友
MapReduce实际上是一个分布式编程框架，你只需要在此编程框架下实现两个方法即可，即map和reduce。map过程实际上就是对数据的处理和映射，假如我们有这样一个文本，内容是I am a student, but also a teacher. 那如果我们要做词频统计，那就需要在map的过程中首先对内容进行分词（英文文本只需要用空格分隔），然后输出形如\u0026lt;I,1\u0026gt;，\u0026lt;am, 1\u0026gt;，\u0026lt;student, 1\u0026gt;的键值对，如果你只需要统计特定单词的话，你也可以对输出进行过滤，只输出你需要的单词的键值对即可。在reduce之前，是shuffle的过程，这一步是MapReduce编程框架帮你做的事，就是将具有相同键值的键值对合并到一起，并分配给执行reduce的节点，即reduce的输入是形如\u0026lt;I,\u0026lt;1,1,1,1,1\u0026gt;\u0026gt;的迭代器，你只需要对后面的值进行累加就可以得到该键I的词频为5，最后将结果输出到文件中。只是最简化的一个过程，当然中间还可以实现combine、partition过程。
我们专注于教育大数据，公众号也正准备开设“大咖解惑”栏目，有大数据专家一对一答疑解惑。如有兴趣可以关注我们，学习时遇到问题欢迎随时过来提问哟
推荐阅读
- 怎样成为一名合格的Python程序员?
- python 爬虫，咋获得输入验证码之后的搜索结果
- dart这编程语言现在发展怎么样了，语法与Java，c#很相似，甚至更简洁
- hadoop中的mapreduce链接（mapreduce chaining）怎样避免中间文件的产生
- python的html5lib这个库咋使用啊我在网上也没有找到相关文档
- 有点计算机基础的人想尽快找份编程的工作。哪种编程的工作最好找还需要学些啥
- 作为软件工程大二的学生，学习一般，编程一般，毕业后能干些啥
- 30岁的人生，想自学一门编程并从事，这个选择怎样呢
- 零基础入门学习啥语言好
- 电子编程书可以边看边练习，价值大吗