| 674 | std::shared_ptr<Schema> TableBatchReader::schema() const { return table_.schema(); } |
| 675 | |
| 676 | void TableBatchReader::set_chunksize(int64_t chunksize) { max_chunksize_ = chunksize; } |
| 677 | |
| 678 | Status TableBatchReader::ReadNext(std::shared_ptr<RecordBatch>* out) { |
| 679 | if (absolute_row_position_ == table_.num_rows()) { |
no outgoing calls