@@ -1857,8 +1857,8 @@ mod test {
18571857 }
18581858
18591859 #[ test]
1860- fn test_decoder_auto_cost_model_keeps_pushdown_for_projected_predicate_with_expensive_deferred_fixed_output (
1861- ) {
1860+ fn test_decoder_auto_cost_model_keeps_pushdown_for_projected_predicate_with_expensive_deferred_fixed_output ( )
1861+ {
18621862 let data = & WIDE_FIXED_COST_MODEL_TEST_FILE_DATA ;
18631863 let builder =
18641864 ParquetPushDecoderBuilder :: try_new_decoder ( parquet_metadata_for_data ( data) ) . unwrap ( ) ;
@@ -1872,7 +1872,10 @@ mod test {
18721872
18731873 let mut decoder = builder
18741874 . with_batch_size ( 100 )
1875- . with_projection ( ProjectionMask :: columns ( & schema_descr, [ "a" , "b" , "c" , "d" , "e" ] ) )
1875+ . with_projection ( ProjectionMask :: columns (
1876+ & schema_descr,
1877+ [ "a" , "b" , "c" , "d" , "e" ] ,
1878+ ) )
18761879 . with_row_selection_policy ( RowSelectionPolicy :: Auto { threshold : 32 } )
18771880 . with_row_filter ( RowFilter :: new ( vec ! [ Box :: new( row_filter_a) ] ) )
18781881 . with_metrics ( metrics. clone ( ) )
@@ -3074,14 +3077,7 @@ mod test {
30743077 let d: ArrayRef = Arc :: new ( Int64Array :: from_iter_values ( 1200 ..1600 ) ) ;
30753078 let e: ArrayRef = Arc :: new ( Int64Array :: from_iter_values ( 1600 ..2000 ) ) ;
30763079
3077- RecordBatch :: try_from_iter ( vec ! [
3078- ( "a" , a) ,
3079- ( "b" , b) ,
3080- ( "c" , c) ,
3081- ( "d" , d) ,
3082- ( "e" , e) ,
3083- ] )
3084- . unwrap ( )
3080+ RecordBatch :: try_from_iter ( vec ! [ ( "a" , a) , ( "b" , b) , ( "c" , c) , ( "d" , d) , ( "e" , e) ] ) . unwrap ( )
30853081 } ) ;
30863082
30873083 static WIDE_FIXED_COST_MODEL_TEST_FILE_DATA : LazyLock < Bytes > =
0 commit comments