| 1280 | } // namespace |
| 1281 | |
| 1282 | Status GetKeyValueMetadata(const KVVector* fb_metadata, |
| 1283 | std::shared_ptr<KeyValueMetadata>* out) { |
| 1284 | if (fb_metadata == nullptr) { |
| 1285 | *out = nullptr; |
| 1286 | return Status::OK(); |
| 1287 | } |
| 1288 | |
| 1289 | auto metadata = std::make_shared<KeyValueMetadata>(); |
| 1290 | |
| 1291 | metadata->reserve(fb_metadata->size()); |
| 1292 | for (const auto pair : *fb_metadata) { |
| 1293 | CHECK_FLATBUFFERS_NOT_NULL(pair->key(), "custom_metadata.key"); |
| 1294 | CHECK_FLATBUFFERS_NOT_NULL(pair->value(), "custom_metadata.value"); |
| 1295 | metadata->Append(pair->key()->str(), pair->value()->str()); |
| 1296 | } |
| 1297 | |
| 1298 | *out = std::move(metadata); |
| 1299 | return Status::OK(); |
| 1300 | } |
| 1301 | |
| 1302 | Status WriteSchemaMessage(const Schema& schema, const DictionaryFieldMapper& mapper, |
| 1303 | const IpcWriteOptions& options, std::shared_ptr<Buffer>* out) { |
no test coverage detected