Skip to content

Commit d43aca4

Browse files
committed
fix split
1 parent 1584a91 commit d43aca4

File tree

1 file changed

+19
-1
lines changed

1 file changed

+19
-1
lines changed

datafusion/core/benches/sql_planner.rs

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -188,9 +188,27 @@ fn criterion_benchmark(c: &mut Criterion) {
188188
// --- TPC-DS ---
189189

190190
let tpcds_ctx = register_defs(SessionContext::new(), tpcds_schemas());
191-
let all_tpcds_sql_queries = (1..100)
191+
192+
let ignored = [
193+
// Physical plan does not support logical expression Exists(<subquery>)
194+
10,
195+
// Physical plan does not support logical expression Exists(<subquery>)
196+
35, // : Optimizing disjunctions not supported
197+
41, // Physical plan does not support logical expression (<subquery>)
198+
45,
199+
];
200+
201+
let raw_tpcds_sql_queries = (1..100)
202+
.filter(|q| !ignored.contains(q))
192203
.map(|q| std::fs::read_to_string(format!("./tests/tpc-ds/{q}.sql")).unwrap())
193204
.collect::<Vec<_>>();
205+
206+
// some queries have multiple statements
207+
let all_tpcds_sql_queries = raw_tpcds_sql_queries
208+
.iter()
209+
.flat_map(|sql| sql.split(';').filter(|s| !s.trim().is_empty()))
210+
.collect::<Vec<_>>();
211+
194212
c.bench_function("physical_plan_tpcds_all", |b| {
195213
b.iter(|| {
196214
for sql in &all_tpcds_sql_queries {

0 commit comments

Comments
 (0)