Function createRawPartitionFields

be/src/runtime/dml-exec-state.cc:580–591

}

vector<flatbuffers::Offset<org::apache::impala::fb::FbIcebergPartitionField>>
createRawPartitionFields(flatbuffers::FlatBufferBuilder& fbb,
    const OutputPartition& partition) {
  using namespace org::apache::impala::fb;
  vector<flatbuffers::Offset<FbIcebergPartitionField>> raw_partition_fields;
  for (const string& partition_name : partition.raw_partition_names) {
    auto data = reinterpret_cast<const uint8_t*>(partition_name.data());
    auto fb_vector = fbb.CreateVector(data, partition_name.size());
    raw_partition_fields.push_back(CreateFbIcebergPartitionField(fbb, fb_vector));
  }
  return raw_partition_fields;
}

// Helper function to create an Iceberg data file FlatBuffer with deletion vectors.
// Used for puffin files where we need to create one entry per data file with DVs.