定義 Reducer

package cn.learn.mapreduce_reduce_join;import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Reducer;import java.io.IOException;public class ReduceJoinReducer extends Reducer<Text,Text,Text,Text> {@Overrideprotected void reduce(Text key, Iterable<Text> values, Context context) throws IOException, InterruptedException {String first = "";String second = "";for (Text value : values) {if(value.toString().startsWith("p")){first = value.toString();}else{second = value.toString();}}if(first.equals("")){context.write(key, new Text("NULL"+"\t"+second));}else{context.write(key, new Text(first+"\t"+second));}} }

?

總結(jié)

以上是生活随笔為你收集整理的MapReduce-Reduce端join操作-Reducer阶段代码的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。