| 68 | virtual WriteProperties GetProperties() = 0; |
| 69 | |
| 70 | void DoWrite(const Table& table) { |
| 71 | Initialize(); |
| 72 | ASSERT_OK(WriteTable(table, stream_.get(), GetProperties())); |
| 73 | ASSERT_OK_AND_ASSIGN(output_, stream_->Finish()); |
| 74 | auto buffer = std::make_shared<io::BufferReader>(output_); |
| 75 | ASSERT_OK_AND_ASSIGN(reader_, Reader::Open(buffer)); |
| 76 | } |
| 77 | |
| 78 | void CheckSlice(std::shared_ptr<RecordBatch> batch, int start, int size) { |
| 79 | batch = batch->Slice(start, size); |
nothing calls this directly
no test coverage detected