MapReduce程序開發之流量求和(八)

1.分析記錄手機流量的日誌。 2.拿到日誌中的一行數據,切分各個字段,抽取出我們需要的字段:手機號,上行流量,下行流量,然後封裝成kv發送出去 3.使用java中的map方法;   public class FlowNumMapper extends Mapper<LongWritable,Text,Text,FlowBean> { @Override protected void map(Lon
相關文章
相關標籤/搜索