MapReduce python编程,你是用什么方法来统计特定单词出现次数的呢?
使用MapReduce的streaming来调用python脚本处理每一行数据,比如单词的切割,python脚本将处理的结果通过streaming返回给java程序。然后在reducer聚合再调用你的python脚本实现每个词的累加。
`单行代码`
关注海汼部落技术社区