| 865 | int64_t bytes_read() const override { return bytes_decoded_->load(); } |
| 866 | |
| 867 | Status ReadNext(std::shared_ptr<RecordBatch>* batch) override { |
| 868 | auto next_fut = ReadNextAsync(); |
| 869 | auto next_result = next_fut.result(); |
| 870 | return std::move(next_result).Value(batch); |
| 871 | } |
| 872 | |
| 873 | Future<std::shared_ptr<RecordBatch>> ReadNextAsync() override { |
| 874 | return record_batch_gen_(); |