这边我们使用Python的M/R框架MRJob来分析.
Mapper:将以行数据解析成>
Shuffle: 通过Shuffle后的结果会生成以 key 的值排序的 value迭代器
结果如: 09 [1, 1, 1 … 1, 1]
Reduce:在这边我们计算出 09 这一小时的访问量
输出如: 09 sum([1, 1, 1 … 1, 1])
猜你喜欢
QQ:800-70898
156-3892-6688