pub fn arrow_stream_to_lance_stream( arrow_stream: BoxStream<'static, Result<RecordBatch, ArrowError>>, ) -> BatchStream