Skip to content

Commit 6eb40b7

Browse files
author
B Vadlamani
committed
add_existence_benchmarks_hashjoin
1 parent a9d6d68 commit 6eb40b7

1 file changed

Lines changed: 84 additions & 120 deletions

File tree

‎datafusion/physical-plan/benches/hash_join_semi_anti.rs‎

Lines changed: 84 additions & 120 deletions
Original file line numberDiff line numberDiff line change
@@ -171,96 +171,78 @@ fn bench_hash_join_semi_anti(c: &mut Criterion) {
171171
{
172172
let left_batches = build_batches(build_rows, build_rows, 0, &s);
173173
let right_batches = build_batches(probe_rows, build_rows, 0, &s);
174-
group.bench_function(
175-
BenchmarkId::new("right_semi_d100_h100", probe_rows),
176-
|b| {
177-
b.iter(|| {
178-
let left = make_exec(&left_batches, &s);
179-
let right = make_exec(&right_batches, &s);
180-
do_hash_join(left, right, JoinType::RightSemi, &rt)
181-
})
182-
},
183-
);
174+
group.bench_function(BenchmarkId::new("right_semi_d100_h100", probe_rows), |b| {
175+
b.iter(|| {
176+
let left = make_exec(&left_batches, &s);
177+
let right = make_exec(&right_batches, &s);
178+
do_hash_join(left, right, JoinType::RightSemi, &rt)
179+
})
180+
});
184181
}
185182

186183
// RightSemi - 100% Density, 10% hit rate
187184
{
188185
let left_batches = build_batches(build_rows, build_rows, 0, &s);
189186
let right_batches = build_batches(probe_rows, build_rows * 10, 0, &s);
190-
group.bench_function(
191-
BenchmarkId::new("right_semi_d100_h10", probe_rows),
192-
|b| {
193-
b.iter(|| {
194-
let left = make_exec(&left_batches, &s);
195-
let right = make_exec(&right_batches, &s);
196-
do_hash_join(left, right, JoinType::RightSemi, &rt)
197-
})
198-
},
199-
);
187+
group.bench_function(BenchmarkId::new("right_semi_d100_h10", probe_rows), |b| {
188+
b.iter(|| {
189+
let left = make_exec(&left_batches, &s);
190+
let right = make_exec(&right_batches, &s);
191+
do_hash_join(left, right, JoinType::RightSemi, &rt)
192+
})
193+
});
200194
}
201195

202196
// RightSemi - 50% Density, 100% hit rate
203197
{
204198
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 2, &s);
205199
let right_batches = build_batches_sparse(probe_rows, build_rows, 0, 2, &s);
206-
group.bench_function(
207-
BenchmarkId::new("right_semi_d50_h100", probe_rows),
208-
|b| {
209-
b.iter(|| {
210-
let left = make_exec(&left_batches, &s);
211-
let right = make_exec(&right_batches, &s);
212-
do_hash_join(left, right, JoinType::RightSemi, &rt)
213-
})
214-
},
215-
);
200+
group.bench_function(BenchmarkId::new("right_semi_d50_h100", probe_rows), |b| {
201+
b.iter(|| {
202+
let left = make_exec(&left_batches, &s);
203+
let right = make_exec(&right_batches, &s);
204+
do_hash_join(left, right, JoinType::RightSemi, &rt)
205+
})
206+
});
216207
}
217208

218209
// RightSemi - 50% Density, 10% hit rate
219210
{
220211
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 2, &s);
221212
let right_batches = build_batches_sparse(probe_rows, build_rows * 10, 0, 2, &s);
222-
group.bench_function(
223-
BenchmarkId::new("right_semi_d50_h10", probe_rows),
224-
|b| {
225-
b.iter(|| {
226-
let left = make_exec(&left_batches, &s);
227-
let right = make_exec(&right_batches, &s);
228-
do_hash_join(left, right, JoinType::RightSemi, &rt)
229-
})
230-
},
231-
);
213+
group.bench_function(BenchmarkId::new("right_semi_d50_h10", probe_rows), |b| {
214+
b.iter(|| {
215+
let left = make_exec(&left_batches, &s);
216+
let right = make_exec(&right_batches, &s);
217+
do_hash_join(left, right, JoinType::RightSemi, &rt)
218+
})
219+
});
232220
}
233221

234222
// RightSemi - 10% Density, 100% hit rate
235223
{
236224
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 10, &s);
237225
let right_batches = build_batches_sparse(probe_rows, build_rows, 0, 10, &s);
238-
group.bench_function(
239-
BenchmarkId::new("right_semi_d10_h100", probe_rows),
240-
|b| {
241-
b.iter(|| {
242-
let left = make_exec(&left_batches, &s);
243-
let right = make_exec(&right_batches, &s);
244-
do_hash_join(left, right, JoinType::RightSemi, &rt)
245-
})
246-
},
247-
);
226+
group.bench_function(BenchmarkId::new("right_semi_d10_h100", probe_rows), |b| {
227+
b.iter(|| {
228+
let left = make_exec(&left_batches, &s);
229+
let right = make_exec(&right_batches, &s);
230+
do_hash_join(left, right, JoinType::RightSemi, &rt)
231+
})
232+
});
248233
}
249234

250235
// RightSemi - 10% Density, 10% hit rate
251236
{
252237
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 10, &s);
253238
let right_batches = build_batches_sparse(probe_rows, build_rows * 10, 0, 10, &s);
254-
group.bench_function(
255-
BenchmarkId::new("right_semi_d10_h10", probe_rows),
256-
|b| {
257-
b.iter(|| {
258-
let left = make_exec(&left_batches, &s);
259-
let right = make_exec(&right_batches, &s);
260-
do_hash_join(left, right, JoinType::RightSemi, &rt)
261-
})
262-
},
263-
);
239+
group.bench_function(BenchmarkId::new("right_semi_d10_h10", probe_rows), |b| {
240+
b.iter(|| {
241+
let left = make_exec(&left_batches, &s);
242+
let right = make_exec(&right_batches, &s);
243+
do_hash_join(left, right, JoinType::RightSemi, &rt)
244+
})
245+
});
264246
}
265247

266248
// =========================================================================
@@ -271,96 +253,78 @@ fn bench_hash_join_semi_anti(c: &mut Criterion) {
271253
{
272254
let left_batches = build_batches(build_rows, build_rows, 0, &s);
273255
let right_batches = build_batches(probe_rows, build_rows, 0, &s);
274-
group.bench_function(
275-
BenchmarkId::new("right_anti_d100_h100", probe_rows),
276-
|b| {
277-
b.iter(|| {
278-
let left = make_exec(&left_batches, &s);
279-
let right = make_exec(&right_batches, &s);
280-
do_hash_join(left, right, JoinType::RightAnti, &rt)
281-
})
282-
},
283-
);
256+
group.bench_function(BenchmarkId::new("right_anti_d100_h100", probe_rows), |b| {
257+
b.iter(|| {
258+
let left = make_exec(&left_batches, &s);
259+
let right = make_exec(&right_batches, &s);
260+
do_hash_join(left, right, JoinType::RightAnti, &rt)
261+
})
262+
});
284263
}
285264

286265
// RightAnti - 100% Density, 10% hit rate (90% output)
287266
{
288267
let left_batches = build_batches(build_rows, build_rows, 0, &s);
289268
let right_batches = build_batches(probe_rows, build_rows * 10, 0, &s);
290-
group.bench_function(
291-
BenchmarkId::new("right_anti_d100_h10", probe_rows),
292-
|b| {
293-
b.iter(|| {
294-
let left = make_exec(&left_batches, &s);
295-
let right = make_exec(&right_batches, &s);
296-
do_hash_join(left, right, JoinType::RightAnti, &rt)
297-
})
298-
},
299-
);
269+
group.bench_function(BenchmarkId::new("right_anti_d100_h10", probe_rows), |b| {
270+
b.iter(|| {
271+
let left = make_exec(&left_batches, &s);
272+
let right = make_exec(&right_batches, &s);
273+
do_hash_join(left, right, JoinType::RightAnti, &rt)
274+
})
275+
});
300276
}
301277

302278
// RightAnti - 50% Density, 100% hit rate (no output)
303279
{
304280
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 2, &s);
305281
let right_batches = build_batches_sparse(probe_rows, build_rows, 0, 2, &s);
306-
group.bench_function(
307-
BenchmarkId::new("right_anti_d50_h100", probe_rows),
308-
|b| {
309-
b.iter(|| {
310-
let left = make_exec(&left_batches, &s);
311-
let right = make_exec(&right_batches, &s);
312-
do_hash_join(left, right, JoinType::RightAnti, &rt)
313-
})
314-
},
315-
);
282+
group.bench_function(BenchmarkId::new("right_anti_d50_h100", probe_rows), |b| {
283+
b.iter(|| {
284+
let left = make_exec(&left_batches, &s);
285+
let right = make_exec(&right_batches, &s);
286+
do_hash_join(left, right, JoinType::RightAnti, &rt)
287+
})
288+
});
316289
}
317290

318291
// RightAnti - 50% Density, 10% hit rate (90% output)
319292
{
320293
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 2, &s);
321294
let right_batches = build_batches_sparse(probe_rows, build_rows * 10, 0, 2, &s);
322-
group.bench_function(
323-
BenchmarkId::new("right_anti_d50_h10", probe_rows),
324-
|b| {
325-
b.iter(|| {
326-
let left = make_exec(&left_batches, &s);
327-
let right = make_exec(&right_batches, &s);
328-
do_hash_join(left, right, JoinType::RightAnti, &rt)
329-
})
330-
},
331-
);
295+
group.bench_function(BenchmarkId::new("right_anti_d50_h10", probe_rows), |b| {
296+
b.iter(|| {
297+
let left = make_exec(&left_batches, &s);
298+
let right = make_exec(&right_batches, &s);
299+
do_hash_join(left, right, JoinType::RightAnti, &rt)
300+
})
301+
});
332302
}
333303

334304
// RightAnti - 10% Density, 100% hit rate (no output)
335305
{
336306
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 10, &s);
337307
let right_batches = build_batches_sparse(probe_rows, build_rows, 0, 10, &s);
338-
group.bench_function(
339-
BenchmarkId::new("right_anti_d10_h100", probe_rows),
340-
|b| {
341-
b.iter(|| {
342-
let left = make_exec(&left_batches, &s);
343-
let right = make_exec(&right_batches, &s);
344-
do_hash_join(left, right, JoinType::RightAnti, &rt)
345-
})
346-
},
347-
);
308+
group.bench_function(BenchmarkId::new("right_anti_d10_h100", probe_rows), |b| {
309+
b.iter(|| {
310+
let left = make_exec(&left_batches, &s);
311+
let right = make_exec(&right_batches, &s);
312+
do_hash_join(left, right, JoinType::RightAnti, &rt)
313+
})
314+
});
348315
}
349316

350317
// RightAnti - 10% Density, 10% hit rate (90% output)
351318
{
352319
let left_batches = build_batches_sparse(build_rows, build_rows, 0, 10, &s);
353320
let right_batches = build_batches_sparse(probe_rows, build_rows * 10, 0, 10, &s);
354-
group.bench_function(
355-
BenchmarkId::new("right_anti_d10_h10", probe_rows),
356-
|b| {
357-
b.iter(|| {
358-
let left = make_exec(&left_batches, &s);
359-
let right = make_exec(&right_batches, &s);
360-
do_hash_join(left, right, JoinType::RightAnti, &rt)
361-
})
362-
},
363-
);
321+
group.bench_function(BenchmarkId::new("right_anti_d10_h10", probe_rows), |b| {
322+
b.iter(|| {
323+
let left = make_exec(&left_batches, &s);
324+
let right = make_exec(&right_batches, &s);
325+
do_hash_join(left, right, JoinType::RightAnti, &rt)
326+
})
327+
});
364328
}
365329

366330
group.finish();

0 commit comments

Comments
 (0)