tustvold opened a new issue, #5039:
URL: https://github.com/apache/arrow-datafusion/issues/5039
**Is your feature request related to a problem or challenge? Please describe
what you are trying to do.**
The is a significant amount of logic converting from DataFusionError to
ArrowError and back, a large amount of which originates from the fact
`SendableRecordBatchStream` returns `ArrowError` instead of `DataFusionError`
**Describe the solution you'd like**
It seems strange that the DataFusion stream abstraction would not return
DataFusion's error type. I would like to change `SendableRecordBatchStream` to
```
pub trait RecordBatchStream: Stream<Item = Result<RecordBatch,
DataFusionError>> {
/// Returns the schema of this `RecordBatchStream`.
///
/// Implementation of this trait should guarantee that all
`RecordBatch`'s returned by this
/// stream should have the same schema as returned from this method.
fn schema(&self) -> SchemaRef;
}
```
**Describe alternatives you've considered**
We could not do this
**Additional context**
Add any other context or screenshots about the feature request here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
