hadoop的NullWritable

2024年3月23日 173次阅读 来源: MapReduce

NullWritable是Writable的一个特殊类，实现方法为空实现，不从数据流中读数据，也不写入数据，只充当占位符，如在MapReduce中，如果你不需要使用键或值，你就可以将键或值声明为NullWritable,NullWritable是一个不可变的单实例类型。

比如，我设置map的输出为<key,空>，这样做：

1 public class IPCountMapper extends Mapper<LongWritable, Text, Text, NullWritable> {
2 
3     @Override
4     protected void map(LongWritable key, Text value, Mapper<LongWritable, Text, Text, NullWritable>.Context context)
5             throws IOException, InterruptedException {
6         String parseIP = LogParseUtil.parseIP(value.toString());
7         context.write(new Text(parseIP), NullWritable.get());
8     }

不能使用new NullWritable()来定义，获取空值只能NullWritable.get()来获取

    原文作者：MapReduce
    原文地址: https://www.cnblogs.com/Skyar/p/5815486.html
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞