Function serializeRowVector

bolt/serializers/PrestoSerializer.cpp:1824–1863

}

void serializeRowVector(
    const BaseVector* vector,
    const folly::Range<const IndexRange*>& ranges,
    VectorStream* stream) {
  if (isTimestampWithTimeZoneType(vector->type())) {
    auto rowVector = dynamic_cast<const RowVector*>(vector);
    serializeTimestampWithTimeZone(rowVector, ranges, stream);
    return;
  }

  const std::vector<VectorPtr>* children;
  size_t childrenSize;
  if (vector->encoding() == VectorEncoding::Simple::ROW) {
    auto rowVector = vector->asUnchecked<RowVector>();
    children = &rowVector->children();
    childrenSize = rowVector->childrenSize();
  } else {
    auto variantVector = vector->asUnchecked<VariantVector>();
    children = &variantVector->children();
    childrenSize = variantVector->childrenSize();
  }

  std::vector<IndexRange> childRanges;
  for (int32_t i = 0; i < ranges.size(); ++i) {
    auto begin = ranges[i].begin;
    auto end = begin + ranges[i].size;
    for (auto offset = begin; offset < end; ++offset) {
      if (vector->isNullAt(offset)) {
        stream->appendNull();
      } else {
        stream->appendNonNull();
        stream->appendLength(1);
        childRanges.push_back(IndexRange{offset, 1});
      }
    }
  }
  for (int32_t i = 0; i < childrenSize; ++i) {
    serializeColumn((*children)[i].get(), childRanges, stream->childAt(i));
  }
}

void serializeArrayVector(
    const BaseVector* vector,