Method new

benchmarks/src/sql_benchmark.rs:73–105

(
        ctx: &SessionContext,
        full_path: impl AsRef<Path>,
        benchmark_directory: impl AsRef<Path>,
    )

impl SqlBenchmark {
    pub async fn new(
        ctx: &SessionContext,
        full_path: impl AsRef<Path>,
        benchmark_directory: impl AsRef<Path>,
    ) -> Result<Self> {
        let full_path = full_path.as_ref();
        let benchmark_directory = benchmark_directory.as_ref();
        let group_name = parse_group_from_path(full_path, benchmark_directory);
        let mut bm = Self {
            name: String::new(),
            group: group_name,
            subgroup: String::new(),
            benchmark_path: full_path.to_path_buf(),
            replacement_mapping: HashMap::new(),
            expect: vec![],
            queries: HashMap::new(),
            result_queries: vec![],
            assert_queries: vec![],
            is_loaded: false,
            last_results: None,
            echo: vec![],
        };
        insert_replacement(
            &mut bm.replacement_mapping,
            "BENCHMARK_DIR",
            benchmark_directory.to_string_lossy().into_owned(),
        );

        let path = bm.benchmark_path.clone();
        bm.process_file(ctx, &path).await?;

        Ok(bm)
    }

    /// Initializes the benchmark by executing `load` and `init` queries.
    ///