Method serialize

bolt/serializers/PrestoSerializer.cpp:3484–3508

        codec_(common::compressionKindToCodec(compressionKind)) {}

  void serialize(
      const RowVectorPtr& vector,
      const folly::Range<const IndexRange*>& ranges,
      Scratch& /* scratch */,
      OutputStream* stream) override {
    const auto numRows = rangesTotalSize(ranges);
    const auto rowType = vector->type();
    const auto numChildren = vector->childrenSize();

    StreamArena arena(pool_);
    std::vector<std::unique_ptr<VectorStream>> streams(numChildren);
    for (int i = 0; i < numChildren; i++) {
      streams[i] = std::make_unique<VectorStream>(
          rowType->childAt(i),
          std::nullopt,
          vector->childAt(i),
          &arena,
          numRows,
          useLosslessTimestamp_);

      serializeColumn(vector->childAt(i).get(), ranges, streams[i].get());
    }

    flushStreams(streams, numRows, arena, *codec_, stream);
  }

 private:
  memory::MemoryPool* pool_;