Method serialize

bolt/serializers/ArrowSerializer.cpp:753–773

  }

  void serialize(
      const RowVectorPtr& vector,
      const folly::Range<const IndexRange*>& ranges,
      Scratch& scratch,
      OutputStream* stream) override {
    size_t numRows = 0;
    for (const auto& range : ranges) {
      numRows += range.size;
    }
    StreamArena arena(pool_);
    auto serializer = std::make_unique<ArrowVectorSerializer>(
        asRowType(vector->type()),
        std::vector<VectorEncoding::Simple>{},
        static_cast<int32_t>(numRows),
        &arena,
        useLosslessTimestamp_,
        compressionKind_,
        &arrowBridgeOptions_);
    serializer->append(vector, ranges, scratch);
    serializer->flush(stream);
  }

 private:
  memory::MemoryPool* pool_;