| 644 | // Convert a table to a sequence of record batches |
| 645 | |
| 646 | TableBatchReader::TableBatchReader(const Table& table) |
| 647 | : owned_table_(nullptr), |
| 648 | table_(table), |
| 649 | column_data_(table.num_columns()), |
| 650 | chunk_numbers_(table.num_columns(), 0), |
| 651 | chunk_offsets_(table.num_columns(), 0), |
| 652 | absolute_row_position_(0), |
| 653 | max_chunksize_(std::numeric_limits<int64_t>::max()) { |
| 654 | for (int i = 0; i < table.num_columns(); ++i) { |
| 655 | column_data_[i] = table.column(i).get(); |
| 656 | } |
| 657 | DCHECK(table_.Validate().ok()); |
| 658 | } |
| 659 | |
| 660 | TableBatchReader::TableBatchReader(std::shared_ptr<Table> table) |
| 661 | : owned_table_(std::move(table)), |
nothing calls this directly
no test coverage detected