common_datasource::file_format::parquet

Function stream_to_parquet

source
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.