@@ -38,14 +38,15 @@ use parquet::file::properties::{WriterProperties, WriterVersion};
3838use std:: hint:: black_box;
3939use std:: path:: Path ;
4040use std:: sync:: Arc ;
41+ use std:: time:: Duration ;
4142use tempfile:: NamedTempFile ;
4243use tokio:: runtime:: Runtime ;
4344
44- const NUM_BATCHES : usize = 64 ;
45- const WRITE_RECORD_BATCH_SIZE : usize = 4096 ;
46- const ROW_GROUP_ROW_COUNT : usize = 65536 ;
47- const EXPECTED_ROW_GROUPS : usize = 4 ;
48- const LARGE_STRING_LEN : usize = 128 * 1024 ;
45+ const NUM_BATCHES : usize = 2 ;
46+ const WRITE_RECORD_BATCH_SIZE : usize = 256 ;
47+ const ROW_GROUP_ROW_COUNT : usize = 256 ;
48+ const EXPECTED_ROW_GROUPS : usize = 2 ;
49+ const LARGE_STRING_LEN : usize = 16 * 1024 ;
4950
5051fn narrow_schema ( ) -> SchemaRef {
5152 let struct_fields = Fields :: from ( vec ! [
@@ -209,6 +210,9 @@ fn narrow_benchmarks(c: &mut Criterion) {
209210 let ctx = create_context ( & rt, & file_path, "t" ) ;
210211
211212 let mut group = c. benchmark_group ( "narrow_struct" ) ;
213+ group. sample_size ( 10 ) ;
214+ group. warm_up_time ( Duration :: from_secs ( 1 ) ) ;
215+ group. measurement_time ( Duration :: from_secs ( 2 ) ) ;
212216
213217 // baseline: full struct, must decode both leaves
214218 group. bench_function ( "select_struct" , |b| {
@@ -253,6 +257,9 @@ fn wide_benchmarks(c: &mut Criterion) {
253257 let ctx = create_context ( & rt, & file_path, "t" ) ;
254258
255259 let mut group = c. benchmark_group ( "wide_struct" ) ;
260+ group. sample_size ( 10 ) ;
261+ group. warm_up_time ( Duration :: from_secs ( 1 ) ) ;
262+ group. measurement_time ( Duration :: from_secs ( 2 ) ) ;
256263
257264 // baseline: full struct, must decode all 5 leaves
258265 group. bench_function ( "select_struct" , |b| {
@@ -359,6 +366,9 @@ fn nested_benchmarks(c: &mut Criterion) {
359366 let ctx = create_context ( & rt, & file_path, "t" ) ;
360367
361368 let mut group = c. benchmark_group ( "nested_struct" ) ;
369+ group. sample_size ( 10 ) ;
370+ group. warm_up_time ( Duration :: from_secs ( 1 ) ) ;
371+ group. measurement_time ( Duration :: from_secs ( 2 ) ) ;
362372
363373 // baseline: full outer struct, decode all 3 leaves
364374 group. bench_function ( "select_struct" , |b| {
0 commit comments