CleaningJob.java 文件源码

@Override
public void map(Text key, CrawlDatum value,
    OutputCollector<ByteWritable, Text> output, Reporter reporter)
    throws IOException {

  if (value.getStatus() == CrawlDatum.STATUS_DB_GONE
      || value.getStatus() == CrawlDatum.STATUS_DB_DUPLICATE) {
    output.collect(OUT, key);
  }
}