大数据之-Hadoop3.x

大数据之-Hadoop3.x

    然后我们去根据上一节我们分析的需求去写代码实现,首先我们新建一个package,outputformat

然后我们新建一个mapper,LogMapper,可以看到继承系统的hadoop3.1.3的mapper,然后

输入的key,value分别是行号和一行的内容,所以用LongWritable,Text,

然后输出的内容是Text,NullWritable,其中Text,也就是key是一行的内容,然后value我们没用

就用NullWritable补空就可以了.

 

然后我们先去看看准备的输入的数据.