Method process_query

benchmarks/src/sql_benchmark.rs:526–555

(&mut self, splits: &[&str], mut query: String)

    }

    fn process_query(&mut self, splits: &[&str], mut query: String) -> Result<()> {
        debug!("Processing query {query}");

        // Trim and validate.
        query = query.trim().to_string();
        if query.is_empty() {
            return Ok(());
        }

        // remove comments
        query = query
            .lines()
            .filter(|line| !is_comment_line(line))
            .collect::<Vec<_>>()
            .join("\n");

        if query.trim().is_empty() {
            return Ok(());
        }

        query = process_replacements(&query, self.replacement_mapping())?;

        let directive = QueryDirective::parse(splits[0]).ok_or_else(|| {
            exec_datafusion_err!("Invalid query directive: {}", splits[0])
        })?;

        self.queries.entry(directive).or_default().push(query);

        Ok(())
    }

    fn validate_expected_plan(&self, physical_plan: &impl Debug) -> Result<()> {
        if self.expect.is_empty() {