输出收集器hadoop中出现Null指针异常

Question

reduce类的close方法中有输出收集器。输出收集器的格式为<Text, Text>

我传递的是Text name_txt作为键，Text val作为值。

通过打印Text name_txt和Text val，我发现它们都不是null，但当我在输出中设置时，我在output.collect（name_str，val）处得到null指针异常；

为了清楚起见，我附上了下面的代码。请帮忙！

private OutputCollector<Text, Text> output;
public void close() throws IOException {          
  for(int i = 0; i<arraylist.size(); i++)
  {
    String name = arraylist.get(i).getToken();
    Text name_txt = new Text(name);
    System.out.println("name_txt: "+name_txt);
    Text val = new Text("hi");
    output.collect(name_txt, val);         
  }         
}

Answer 1

在哪里设置输出值？

我看到您使用的是旧的API（mapred），所以您没有设置方法的奢侈。相反，您可能需要在地图方法中添加一个条件：

void map(K1 key, V1 value, OutputCollector<K2, V2> output, Reporter reporter)
  throws IOException {
  if (this.output == null) {
    this.output = output;
  }
  // your current map implementation goes here..
}