MCPcopy Create free account
hub / github.com/apache/datafusion / process_results

Method process_results

benchmarks/src/sql_benchmark.rs:970–1001  ·  view source on GitHub ↗
(
        bench: &mut SqlBenchmark,
        reader: &BenchmarkFileReader,
        splits: &[&str],
    )

Source from the content-addressed store, hash-verified

968 }
969
970 fn process_results(
971 bench: &mut SqlBenchmark,
972 reader: &BenchmarkFileReader,
973 splits: &[&str],
974 ) -> Result<()> {
975 if splits.len() <= 1 || splits[1].is_empty() {
976 return Err(exec_datafusion_err!(
977 "{}",
978 reader.format_exception(
979 "result must be followed by a path to a result file"
980 )
981 ));
982 }
983
984 if !bench.result_queries.is_empty() {
985 return Err(exec_datafusion_err!(
986 "{}",
987 reader.format_exception("multiple results found")
988 ));
989 }
990
991 let path = process_replacements(splits[1], &bench.replacement_mapping)?;
992
993 bench.result_queries.push(BenchmarkQuery {
994 path: Some(path),
995 query: String::new(),
996 column_count: 0,
997 expected_result: vec![],
998 });
999
1000 Ok(())
1001 }
1002
1003 fn process_result_query(
1004 bench: &mut SqlBenchmark,

Callers

nothing calls this directly

Calls 5

process_replacementsFunction · 0.85
newFunction · 0.85
lenMethod · 0.45
is_emptyMethod · 0.45
pushMethod · 0.45

Tested by

no test coverage detected