Function query_json_array

datafusion/core/src/datasource/file_format/json.rs:82–88

Register a JSON array table and run a query

(content: &str, query: &str)

    /// Register a JSON array table and run a query
    async fn query_json_array(content: &str, query: &str) -> Result<Vec<RecordBatch>> {
        let (_tmp_dir, path) = create_temp_json(content);
        let ctx = SessionContext::new();
        let options = JsonReadOptions::default().newline_delimited(false);
        ctx.register_json("test_table", &path, options).await?;
        ctx.sql(query).await?.collect().await
    }

    /// Register a JSON array table and run a query, return formatted string
    async fn query_json_array_str(content: &str, query: &str) -> Result<String> {