(
bench: &mut SqlBenchmark,
reader: &BenchmarkFileReader,
splits: &[&str],
)
| 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, |
nothing calls this directly
no test coverage detected