| 683 | std::shared_ptr<Schema> TableBatchReader::schema() const { return table_.schema(); } |
| 684 | |
| 685 | void TableBatchReader::set_chunksize(int64_t chunksize) { max_chunksize_ = chunksize; } |
| 686 | |
| 687 | Status TableBatchReader::ReadNext(std::shared_ptr<RecordBatch>* out) { |
| 688 | if (absolute_row_position_ == table_.num_rows()) { |
no outgoing calls