Reduce 端程序编写

publicclassFlowSumSortReducerextendsReducer<FlowBeanSort, Text, Text, FlowBeanSort> {
/** <FlowBeanSort,电话号> ===> <电话号,FlowBeanSort>*/@Overrideprotectedvoidreduce(FlowBeanSortkey, Iterable<Text>values,
Reducer<FlowBeanSort, Text, Text, FlowBeanSort>.Contextcontext) throwsIOException, InterruptedException {
// 遍历集合for (Texttele : values) {
// 将手机号作为key，将封装好的流量信息作为value，作为最终的输出结果context.write(newText(tele), key);
        }
    }
}