Method write_json

datafusion/core/src/execution/context/json.rs:65–71

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

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

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