Method scan_queries

benchmarks/src/benchmark_runner/suite.rs:151–177

Performs uncached query discovery and duplicate-id validation.

(&self)

    /// Performs uncached query discovery and duplicate-id validation.
    fn scan_queries(&self) -> Result<Vec<SuiteQuery>> {
        let mut queries = Vec::new();

        self.scan_query_dir(self.query_search_root(), &mut queries)?;
        queries.sort_by(|left, right| {
            left.id
                .cmp(&right.id)
                .then_with(|| left.path.cmp(&right.path))
        });

        for pair in queries.windows(2) {
            let [left, right] = pair else {
                continue;
            };
            if left.id == right.id {
                return Err(DataFusionError::Configuration(format!(
                    "duplicate QUERY_ID {} in suite '{}': {} and {}",
                    left.id,
                    self.name,
                    left.path.display(),
                    right.path.display()
                )));
            }
        }

        Ok(queries)
    }

    /// Recursively scans a directory and appends valid query benchmark files to
    /// the provided collection.