| 653 | // Convert a table to a sequence of record batches |
| 654 | |
| 655 | TableBatchReader::TableBatchReader(const Table& table) |
| 656 | : owned_table_(nullptr), |
| 657 | table_(table), |
| 658 | column_data_(table.num_columns()), |
| 659 | chunk_numbers_(table.num_columns(), 0), |
| 660 | chunk_offsets_(table.num_columns(), 0), |
| 661 | absolute_row_position_(0), |
| 662 | max_chunksize_(std::numeric_limits<int64_t>::max()) { |
| 663 | for (int i = 0; i < table.num_columns(); ++i) { |
| 664 | column_data_[i] = table.column(i).get(); |
| 665 | } |
| 666 | DCHECK(table_.Validate().ok()); |
| 667 | } |
| 668 | |
| 669 | TableBatchReader::TableBatchReader(std::shared_ptr<Table> table) |
| 670 | : owned_table_(std::move(table)), |
nothing calls this directly
no test coverage detected