| 1299 | } |
| 1300 | |
| 1301 | Result<std::shared_ptr<Buffer>> WriteSchemaMessage(const Schema& schema, |
| 1302 | const DictionaryFieldMapper& mapper, |
| 1303 | const IpcWriteOptions& options) { |
| 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 | } |
| 1312 | |
| 1313 | Result<std::shared_ptr<Buffer>> WriteRecordBatchMessage( |
| 1314 | int64_t length, int64_t body_length, |
no test coverage detected