| 206 | return Status::OK(); |
| 207 | } |
| 208 | arrow::Result<std::shared_ptr<Schema>> GetSchema() override { |
| 209 | RETURN_NOT_OK(EnsureDataStarted()); |
| 210 | return batch_reader_->schema(); |
| 211 | } |
| 212 | arrow::Result<FlightStreamChunk> Next() override { |
| 213 | FlightStreamChunk out; |
| 214 | internal::FlightData* data; |