pub async fn stream_to_parquet( stream: SendableRecordBatchStream, store: ObjectStore, path: &str, concurrency: usize, ) -> Result<usize>
Output the stream to a parquet file.
Returns number of rows written.