Method process_line

benchmarks/src/sql_benchmark.rs:511–524

(
        &mut self,
        ctx: &SessionContext,
        reader: &mut BenchmarkFileReader,
        line: &mut String,
    )

    }

    async fn process_line(
        &mut self,
        ctx: &SessionContext,
        reader: &mut BenchmarkFileReader,
        line: &mut String,
    ) -> Result<()> {
        // Split the line into directive and arguments.
        let cloned_line = line.trim_start().to_string();
        let splits: Vec<&str> = cloned_line.split_whitespace().collect();

        BenchmarkDirective::select(reader, splits[0])?
            .process(ctx, self, reader, line, &splits)
            .await
    }

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