| 1159 | } |
| 1160 | |
| 1161 | Status ReadNext(std::shared_ptr<RecordBatch>* batch) override { |
| 1162 | ARROW_ASSIGN_OR_RAISE(auto batch_with_metadata, ReadNext()); |
| 1163 | *batch = std::move(batch_with_metadata.batch); |
| 1164 | return Status::OK(); |
| 1165 | } |
| 1166 | |
| 1167 | Result<RecordBatchWithMetadata> ReadNext() override { |
| 1168 | auto collect_listener = checked_cast<CollectListener*>(raw_listener()); |