src/java/org/apache/nutch/crawl/CrawlDbReader.java [220:250]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        out.writeByte('\n');
      }

      @Override
      public synchronized void close(TaskAttemptContext context)
          throws IOException {
        out.close();
      }
    }

    @Override
    public RecordWriter<Text, CrawlDatum> getRecordWriter(
        TaskAttemptContext context) throws IOException {
      Configuration conf = context.getConfiguration();
      boolean isCompressed = FileOutputFormat.getCompressOutput(context);
      CompressionCodec codec = null;
      String extension = "";
      if (isCompressed) {
        Class<? extends CompressionCodec> codecClass = getOutputCompressorClass(
            context, GzipCodec.class);
        codec = ReflectionUtils.newInstance(codecClass, conf);
        extension = codec.getDefaultExtension();
      }
      Path file = getDefaultWorkFile(context, extension);
      FileSystem fs = file.getFileSystem(conf);
      FSDataOutputStream fileOut = fs.create(file, false);
      if (isCompressed) {
        return new LineRecordWriter(
            new DataOutputStream(codec.createOutputStream(fileOut)));
      } else {
        return new LineRecordWriter(fileOut);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/java/org/apache/nutch/crawl/CrawlDbReader.java [303:333]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        out.writeByte('\n');
      }

      @Override
      public synchronized void close(TaskAttemptContext context)
          throws IOException {
        out.close();
      }
    }

    @Override
    public RecordWriter<Text, CrawlDatum> getRecordWriter(
        TaskAttemptContext context) throws IOException {
      Configuration conf = context.getConfiguration();
      boolean isCompressed = FileOutputFormat.getCompressOutput(context);
      CompressionCodec codec = null;
      String extension = "";
      if (isCompressed) {
        Class<? extends CompressionCodec> codecClass = getOutputCompressorClass(
            context, GzipCodec.class);
        codec = ReflectionUtils.newInstance(codecClass, conf);
        extension = codec.getDefaultExtension();
      }
      Path file = getDefaultWorkFile(context, extension);
      FileSystem fs = file.getFileSystem(conf);
      FSDataOutputStream fileOut = fs.create(file, false);
      if (isCompressed) {
        return new LineRecordWriter(
            new DataOutputStream(codec.createOutputStream(fileOut)));
      } else {
        return new LineRecordWriter(fileOut);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -