(
ctx: &SessionContext,
bench: &mut SqlBenchmark,
reader: &BenchmarkFileReader,
splits: &[&str],
)
| 1125 | } |
| 1126 | |
| 1127 | async fn process_include( |
| 1128 | ctx: &SessionContext, |
| 1129 | bench: &mut SqlBenchmark, |
| 1130 | reader: &BenchmarkFileReader, |
| 1131 | splits: &[&str], |
| 1132 | ) -> Result<()> { |
| 1133 | if splits.len() != 2 || splits[1].is_empty() { |
| 1134 | return Err(exec_datafusion_err!( |
| 1135 | "{}", |
| 1136 | reader.format_exception("include requires a single argument") |
| 1137 | )); |
| 1138 | } |
| 1139 | |
| 1140 | Box::pin(bench.process_file(ctx, Path::new(splits[1]))).await |
| 1141 | } |
| 1142 | |
| 1143 | fn process_echo( |
| 1144 | bench: &mut SqlBenchmark, |
nothing calls this directly
no test coverage detected