| 102 | } |
| 103 | |
| 104 | void CheckRoundtrip(std::shared_ptr<RecordBatch> batch) { |
| 105 | std::vector<std::shared_ptr<RecordBatch>> batches = {batch}; |
| 106 | ASSERT_OK_AND_ASSIGN(auto table, Table::FromRecordBatches(batches)); |
| 107 | |
| 108 | DoWrite(*table); |
| 109 | |
| 110 | std::shared_ptr<Table> read_table; |
| 111 | ASSERT_OK(reader_->Read(&read_table)); |
| 112 | ASSERT_OK(read_table->ValidateFull()); |
| 113 | AssertTablesEqual(*table, *read_table); |
| 114 | } |
| 115 | |
| 116 | protected: |
| 117 | std::shared_ptr<io::BufferOutputStream> stream_; |
nothing calls this directly
no test coverage detected