Function writeFlatVector

bolt/vector/VectorSaver.cpp:252–282

}

void writeFlatVector(const BaseVector& vector, std::ostream& out) {
  // Nulls buffer.
  writeOptionalBuffer(vector.nulls(), out);

  // Values buffer.
  if (isVarcharOrVarbinary(vector)) {
    const auto& values = vector.values();
    if (values) {
      write<bool>(true, out);

      const auto& stringBuffers =
          vector.asFlatVector<StringView>()->stringBuffers();
      writeStringViews(vector.size(), values, stringBuffers, out);
    } else {
      write<bool>(false, out);
    }
  } else {
    writeOptionalBuffer(vector.values(), out);
  }

  // String buffers.
  if (isVarcharOrVarbinary(vector)) {
    const auto& stringBuffers =
        vector.asFlatVector<StringView>()->stringBuffers();
    write<int32_t>(stringBuffers.size(), out);

    for (const auto& buffer : stringBuffers) {
      writeBuffer(buffer, out);
    }
  }
}

VectorPtr readFlatVector(
    const TypePtr& type,