public LzopOutputStream()

in src/main/java/com/hadoop/compression/lzo/LzopOutputStream.java [90:105]

• 13 lines of code
• 2 McCabe index (conditional complexity)

  public LzopOutputStream(OutputStream out, DataOutputStream indexOut,
      Compressor compressor, int bufferSize,
      LzoCompressor.CompressionStrategy strategy)
      throws IOException {
    super(new CountingOutputStream(out), compressor, bufferSize);

    this.cout = (CountingOutputStream) this.out;
    this.indexOut = indexOut;
    int overhead = strategy.name().contains("LZO1") ?
      (bufferSize >> 4) + 64 + 3 : (bufferSize >> 3) + 128 + 3;
    MAX_INPUT_SIZE = bufferSize - overhead;

    int compressionLevel = ((LzoCompressor) compressor).getCompressionLevel();

    writeLzopHeader(this.out, strategy, compressionLevel);
  }