| 1300 | } |
| 1301 | |
| 1302 | Status WriteSchemaMessage(const Schema& schema, const DictionaryFieldMapper& mapper, |
| 1303 | const IpcWriteOptions& options, std::shared_ptr<Buffer>* out) { |
| 1304 | FBB fbb; |
| 1305 | flatbuffers::Offset<flatbuf::Schema> fb_schema; |
| 1306 | RETURN_NOT_OK(SchemaToFlatbuffer(fbb, schema, mapper, &fb_schema)); |
| 1307 | return WriteFBMessage(fbb, flatbuf::MessageHeader::MessageHeader_Schema, |
| 1308 | fb_schema.Union(), |
| 1309 | /*body_length=*/0, options.metadata_version, |
| 1310 | /*custom_metadata=*/nullptr, options.memory_pool) |
| 1311 | .Value(out); |
| 1312 | } |
| 1313 | |
| 1314 | Status WriteRecordBatchMessage( |
| 1315 | int64_t length, int64_t body_length, |