plan_to_parquet

datafusion::datasource::physical_plan::parquet

Function plan_to_parquet 

Source 
pub async fn plan_to_parquet(
    task_ctx: Arc<TaskContext>,
    plan: Arc<dyn ExecutionPlan>,
    path: impl AsRef<str>,
    writer_properties: Option<WriterProperties>,
) -> Result<(), DataFusionError>
Expand description

Executes a query and writes the results to a partitioned Parquet file.