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