packagemobvista.dmp.datasource.ga.mapreduce.reduce;importmobvista.dmp.datasource.ga.mapreduce.vo.TextPair;importorg.apache.hadoop.io.NullWritable;importorg.apache.hadoop.io.Text;importorg.apache.hadoop.mapreduce.Reducer;importjava.io.IOException;/** * * Created by fl on 2017/4/26. */publicclassGaActiveTotalReducerextendsReducer<TextPair,Text,NullWritable,Text>{@Overrideprotectedvoidreduce(TextPairkey,Iterable<Text>values,Contextcontext)throwsIOException,InterruptedException{for(Textval:values){context.write(NullWritable.get(),val);break;}}}