Method write_csv

datafusion/core/src/execution/context/csv.rs:87–93

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

(
        &self,
        plan: Arc<dyn ExecutionPlan>,
        path: impl AsRef<str>,
    )

    /// Executes a query and writes the results to a partitioned CSV file.
    pub async fn write_csv(
        &self,
        plan: Arc<dyn ExecutionPlan>,
        path: impl AsRef<str>,
    ) -> Result<()> {
        plan_to_csv(self.task_ctx(), plan, path).await
    }
}

#[cfg(test)]