| 1723 | int NumBatchesRead() { return tracking_generator_.num_read(); } |
| 1724 | |
| 1725 | void Finish() { ARROW_UNUSED(record_batch_generator_.producer().Close()); } |
| 1726 | void DeliverBatch(uint32_t num_rows) { |
| 1727 | auto batch = ConstantArrayGenerator::Zeroes(num_rows, given_physical_schema_); |
| 1728 | record_batch_generator_.producer().Push(std::move(batch)); |