Method spill

java/core/src/java/org/apache/orc/impl/OutStream.java:375–414

()

  }

  private void spill() throws IOException {
    // if there isn't anything in the current buffer, don't spill
    if (current == null ||
        current.position() == (codec == null ? 0 : HEADER_SIZE)) {
      return;
    }
    flip();
    if (codec == null) {
      outputBuffer(current);
      getNewInputBuffer();
    } else {
      compressedBuffer.init();
      int currentPosn = compressedBuffer.getCurrentPosn();
      compressedBuffer.advanceTo(currentPosn + HEADER_SIZE);

      // Worth compression
      if (codec.compress(current, compressedBuffer.compressed,
          compressedBuffer.overflow, options)) {
        // move position back to after the header
        uncompressedBytes = 0;

        current.position(HEADER_SIZE);
        current.limit(current.capacity());

        compressedBytes += compressedBuffer.commitCompress(currentPosn);
      } else {
        compressedBytes += uncompressedBytes + HEADER_SIZE;
        uncompressedBytes = 0;

        compressedBuffer.abortCompress(currentPosn);

        // now add the current buffer into the done list and get a new one.
        current.position(0);
        // update the header with the current length
        writeHeader(current, 0, current.limit() - HEADER_SIZE, true);
        outputBuffer(current);
        getNewInputBuffer();
      }
    }
  }

  @Override
  public void getPosition(PositionRecorder recorder) {