本文共 284 字,大约阅读时间需要 1 分钟。
假如面试时给你一个这样的问题,你怎么解决。
你要知道mapper和reducer工作的原理,从文件里按照key-value,一条一条记录读的,然后对数据做分解处理。
首先通过key-value传进来,每个value就是上图的一条记录,然后根据逗号我来分解他。
获得这个字符串数组,如果第2个元素等于bee,那我就把它写出去。
因为你sql语句,select的是id,所以我把第一个元素作为key写出去。
然后在reducer里,key就是那个id,value还是那条记录,不过我们要查的就是id,所以不用把value写出去。
所以是NullWritable.get()
转载地址:http://ruvws.baihongyu.com/