Map 端程序编写

// 输入数据是上一个统计程序的输出结果，已经是各个手机号的总流量信息publicclassFlowSumSortMapperextendsMapper<LongWritable, Text, FlowBeanSort, Text> {
@Overrideprotectedvoidmap(LongWritablekey, Textvalue, Mapper<LongWritable, Text, FlowBeanSort, Text>.Contextcontext)
throwsIOException, InterruptedException {
// （1）获取一行文本的内容，并将其转换为String类型，之后按照分隔符“\t”进行切分String[] splits=value.toString().split("\t");
// （2）取出手机号Stringtelephone=splits[0];
// （3）封装对象FlowBeanSortfbs=newFlowBeanSort();
fbs.setUpFlow(Long.parseLong(splits[1]));
fbs.setDownFlow(Long.parseLong(splits[2]));
fbs.setSumFlow(Long.parseLong(splits[3]));
// （4）将封装的fbs对象作为key，将手机号作为value，分发给Reduce端context.write(fbs, newText(telephone));
    }
}