Method process

benchmarks/src/sql_benchmark.rs:726–783

(
        &self,
        ctx: &SessionContext,
        bench: &mut SqlBenchmark,
        reader: &mut BenchmarkFileReader,
        line: &mut String,
        splits: &[&str],
    )

    }

    async fn process(
        &self,
        ctx: &SessionContext,
        bench: &mut SqlBenchmark,
        reader: &mut BenchmarkFileReader,
        line: &mut String,
        splits: &[&str],
    ) -> Result<()> {
        trace!("-- handling {}", splits[0]);

        match self {
            BenchmarkDirective::Load
            | BenchmarkDirective::Run
            | BenchmarkDirective::Init
            | BenchmarkDirective::Cleanup => {
                Self::process_query_directive(bench, reader, line, splits)
            }
            BenchmarkDirective::Name => Self::process_metadata_value(
                bench,
                reader,
                line,
                "name",
                "BENCH_NAME",
                "name must be followed by a value",
            ),
            BenchmarkDirective::Group => Self::process_metadata_value(
                bench,
                reader,
                line,
                "group",
                "BENCH_GROUP",
                "group must be followed by a value",
            ),
            BenchmarkDirective::Subgroup => Self::process_metadata_value(
                bench,
                reader,
                line,
                "subgroup",
                "BENCH_SUBGROUP",
                "subgroup must be followed by a value",
            ),
            BenchmarkDirective::Expect => Self::process_expect(bench, reader, splits),
            BenchmarkDirective::Assert => {
                Self::process_assert(bench, reader, line, splits)
            }
            BenchmarkDirective::ResultQuery => {
                Self::process_result_query(bench, reader, line, splits)
            }
            BenchmarkDirective::Results => Self::process_results(bench, reader, splits),
            BenchmarkDirective::Template => {
                Self::process_template(ctx, bench, reader, line, splits).await
            }
            BenchmarkDirective::Include => {
                Self::process_include(ctx, bench, reader, splits).await
            }
            BenchmarkDirective::Echo => Self::process_echo(bench, reader, splits),
        }
    }