time travel bench size

main
Ziyang Hu 2 years ago
parent 4629e03b09
commit cabd00df3d

@ -132,7 +132,9 @@ fn single_tt_read(k: usize) {
let i = rand::thread_rng().gen_range(0..10000); let i = rand::thread_rng().gen_range(0..10000);
TEST_DB TEST_DB
.run_script( .run_script(
&format!(r#"?[vld, v] := *tt{}{{k: $id, vld, v}}"#, k), &format!(r#"
?[min_cost(pack)] := *tt{}{{k: $id, vld, v}}, pack = [v, vld]
"#, k),
BTreeMap::from([("id".to_string(), json!(i))]), BTreeMap::from([("id".to_string(), json!(i))]),
) )
.unwrap(); .unwrap();
@ -142,7 +144,7 @@ fn single_tt_read(k: usize) {
fn time_travel_init(_: &mut Bencher) { fn time_travel_init(_: &mut Bencher) {
initialize(&TEST_DB); initialize(&TEST_DB);
let count = 1_000_000; let count = 100_000;
let qps_single_plain_time = Instant::now(); let qps_single_plain_time = Instant::now();
(0..count).into_par_iter().for_each(|_| { (0..count).into_par_iter().for_each(|_| {
single_plain_read(); single_plain_read();
@ -150,7 +152,7 @@ fn time_travel_init(_: &mut Bencher) {
dbg!((count as f64) / qps_single_plain_time.elapsed().as_secs_f64()); dbg!((count as f64) / qps_single_plain_time.elapsed().as_secs_f64());
for k in [1, 10, 100, 1000] { for k in [1, 10, 100, 1000] {
let count = 1_000_000; let count = 100_000;
let qps_single_tt_time = Instant::now(); let qps_single_tt_time = Instant::now();
(0..count).into_par_iter().for_each(|_| { (0..count).into_par_iter().for_each(|_| {
single_tt_read(k); single_tt_read(k);

Loading…
Cancel
Save