MapReduce 统计手机用户的上行流量,下行流量,总流量,并对输出的结果进行倒序排序。(一)

  首先,要知道hadoop自带的LongWritable 是没办法存储三个变量,即用户的上行流量,下行流量,总流量。 这个时候,没办法,你就要去写一个属于你自己的接口,去实现能够放入这三个数据。 MapReduce中传输自定义数据类型(Bean->setter+getter) (1) 要在Hadoop的各个节点之间传输,就必须实现其序列化机制,实现 Writable接口 ,重写两个方法: rea
相关文章
相关标签/搜索