Method execute_sql_without_result_buffering

benchmarks/src/sql_benchmark.rs:575–596

(
        &self,
        sql: &str,
        ctx: &SessionContext,
    )

    }

    async fn execute_sql_without_result_buffering(
        &self,
        sql: &str,
        ctx: &SessionContext,
    ) -> Result<usize> {
        let mut row_count = 0;

        let df = ctx.sql(sql).await?;
        let physical_plan = df.create_physical_plan().await?;

        self.validate_expected_plan(&physical_plan)?;
        let mut stream = execute_stream(physical_plan, ctx.task_ctx())?;

        while let Some(batch) = stream.next().await {
            row_count += batch?.num_rows();

            // Evaluate the result and do nothing, the result will be dropped
            // to reduce memory pressure
        }

        Ok(row_count)
    }

    pub fn name(&self) -> &str {
        &self.name