Function flushUncompressed

bolt/serializers/PrestoSerializer.cpp:3255–3333

}

void flushUncompressed(
    const std::vector<std::unique_ptr<VectorStream>>& streams,
    int32_t numRows,
    OutputStream* out,
    PrestoOutputStreamListener* listener) {
  const auto offset = out->tellp();

  char codecMask = 0;
#ifdef BOLT_ENABLE_CRC
  if (listener) {
    codecMask = getCodecMarker();
  }
#endif
  // Pause CRC computation
  if (listener) {
    listener->pause();
  }

  writeInt32(out, numRows);
  out->write(&codecMask, 1);

  // Make space for uncompressedSizeInBytes & sizeInBytes
  writeInt32(out, 0);
  writeInt32(out, 0);
#ifdef BOLT_ENABLE_CRC
  // Write zero checksum.
  writeInt64(out, 0);

  // Number of columns and stream content. Unpause CRC.
  if (listener) {
    listener->resume();
  }
#endif
  writeInt32(out, streams.size());

  for (auto& stream : streams) {
    stream->flush(out);
  }

#ifdef BOLT_ENABLE_CRC
  // Pause CRC computation
  if (listener) {
    listener->pause();
  }
#endif

  // Fill in uncompressedSizeInBytes & sizeInBytes
  const auto endOffset = out->tellp();
  const auto size = static_cast<int64_t>(endOffset - offset);
  BOLT_CHECK(
      size > kHeaderSize,
      "serialized page size {} should exceed header size {}, numRows {}",
      size,
      kHeaderSize,
      numRows);

  const int64_t uncompressedSize64 = size - kHeaderSize;
  BOLT_CHECK(