| 435 | } |
| 436 | |
| 437 | Result<std::shared_ptr<RecordBatch>> DoStandardRoundTrip( |
| 438 | const RecordBatch& batch, const IpcWriteOptions& options, |
| 439 | DictionaryMemo* dictionary_memo, |
| 440 | const IpcReadOptions& read_options = IpcReadOptions::Defaults()) { |
| 441 | ARROW_ASSIGN_OR_RAISE(std::shared_ptr<Buffer> serialized_batch, |
| 442 | SerializeRecordBatch(batch, options)); |
| 443 | |
| 444 | io::BufferReader buf_reader(serialized_batch); |
| 445 | return ReadRecordBatch(batch.schema(), dictionary_memo, read_options, &buf_reader); |
| 446 | } |
| 447 | |
| 448 | Result<std::shared_ptr<RecordBatch>> DoLargeRoundTrip(const RecordBatch& batch, |
| 449 | bool zero_data) { |
nothing calls this directly
no test coverage detected