Function readArrayVector

bolt/serializers/PrestoSerializer.cpp:539–577

}

void readArrayVector(
    ByteInputStream* source,
    const TypePtr& type,
    bolt::memory::MemoryPool* pool,
    VectorPtr& result,
    vector_size_t resultOffset,
    bool useLosslessTimestamp) {
  ArrayVector* arrayVector = result->as<ArrayVector>();

  const auto resultElementsOffset = arrayVector->elements()->size();

  std::vector<TypePtr> childTypes = {type->childAt(0)};
  std::vector<VectorPtr> children{arrayVector->elements()};
  readColumns(
      source,
      pool,
      childTypes,
      children,
      resultElementsOffset,
      useLosslessTimestamp);

  vector_size_t size = source->read<int32_t>();
  arrayVector->resize(resultOffset + size);
  arrayVector->setElements(children[0]);

  BufferPtr offsets = arrayVector->mutableOffsets(resultOffset + size);
  auto rawOffsets = offsets->asMutable<vector_size_t>();
  BufferPtr sizes = arrayVector->mutableSizes(resultOffset + size);
  auto rawSizes = sizes->asMutable<vector_size_t>();
  int32_t base = source->read<int32_t>();
  for (int32_t i = 0; i < size; ++i) {
    int32_t offset = source->read<int32_t>();
    rawOffsets[resultOffset + i] = resultElementsOffset + base;
    rawSizes[resultOffset + i] = offset - base;
    base = offset;
  }

  readNulls(source, size, *arrayVector, resultOffset);
}

void readMapVector(
    ByteInputStream* source,