自定义复杂类型

access.log
第二个字段:手机号
倒数第三个字段:上行流量
倒数第二个字段:下行流量
需求:统计每个手机号上行流量和、下行流量和、总的流量和(上行流量和+下行流量和)

Access.java
手机号、上行流量、下行流量、总流量

既然要求和:就要根据手机号进行分组

Mapper 阶段:把手机号 上行流量 下行流量 拆开
把手机号作为key, 把Access作为value写出去

Reducer:(1371111111,<Access,Access>)

流量统计实战之自定义复杂数据类型
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求
Hadoop 流量统计实战之需求

相关文章:

  • 2022-12-23
  • 2021-08-08
  • 2022-02-22
  • 2022-12-23
  • 2022-12-23
  • 2021-10-09
  • 2022-01-16
猜你喜欢
  • 2022-12-23
  • 2022-02-09
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-10-27
  • 2021-09-23
相关资源
相似解决方案