| 1164 | } |
| 1165 | |
| 1166 | Status ReadNext(std::shared_ptr<RecordBatch>* batch) override { |
| 1167 | ARROW_ASSIGN_OR_RAISE(auto batch_with_metadata, ReadNext()); |
| 1168 | *batch = std::move(batch_with_metadata.batch); |
| 1169 | return Status::OK(); |
| 1170 | } |
| 1171 | |
| 1172 | Result<RecordBatchWithMetadata> ReadNext() override { |
| 1173 | auto collect_listener = checked_cast<CollectListener*>(raw_listener()); |