| 1025 | } |
| 1026 | |
| 1027 | static Status GetBodyCompression(FBB& fbb, const IpcWriteOptions& options, |
| 1028 | BodyCompressionOffset* out) { |
| 1029 | if (options.codec != nullptr) { |
| 1030 | flatbuf::CompressionType codec; |
| 1031 | if (options.codec->compression_type() == Compression::LZ4_FRAME) { |
| 1032 | codec = flatbuf::CompressionType::CompressionType_LZ4_FRAME; |
| 1033 | } else if (options.codec->compression_type() == Compression::ZSTD) { |
| 1034 | codec = flatbuf::CompressionType::CompressionType_ZSTD; |
| 1035 | } else { |
| 1036 | return Status::Invalid("Unsupported IPC compression codec: ", |
| 1037 | options.codec->name()); |
| 1038 | } |
| 1039 | *out = flatbuf::CreateBodyCompression( |
| 1040 | fbb, codec, flatbuf::BodyCompressionMethod::BodyCompressionMethod_BUFFER); |
| 1041 | } |
| 1042 | return Status::OK(); |
| 1043 | } |
| 1044 | |
| 1045 | static Status MakeRecordBatch(FBB& fbb, int64_t length, int64_t body_length, |
| 1046 | const std::vector<FieldMetadata>& nodes, |
no test coverage detected