File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -35,10 +35,7 @@ fn decode_all(
3535 batches
3636}
3737
38- fn decode_all_arrow_csv (
39- raw : & [ u8 ] ,
40- schema : Arc < Schema > ,
41- ) -> Vec < arrow_array:: RecordBatch > {
38+ fn decode_all_arrow_csv ( raw : & [ u8 ] , schema : Arc < Schema > ) -> Vec < arrow_array:: RecordBatch > {
4239 let mut decoder = arrow_csv:: ReaderBuilder :: new ( schema)
4340 . with_header ( true )
4441 . with_batch_size ( 8192 )
@@ -79,7 +76,11 @@ fn arrow_csv2_matches_arrow_csv() {
7976 assert_eq ! ( ours. len( ) , theirs. len( ) , "batch count mismatch" ) ;
8077
8178 for ( i, ( a, b) ) in ours. iter ( ) . zip ( & theirs) . enumerate ( ) {
82- assert_eq ! ( a. num_rows( ) , b. num_rows( ) , "row count mismatch in batch {i}" ) ;
79+ assert_eq ! (
80+ a. num_rows( ) ,
81+ b. num_rows( ) ,
82+ "row count mismatch in batch {i}"
83+ ) ;
8384 assert_eq ! (
8485 a. num_columns( ) ,
8586 b. num_columns( ) ,
You can’t perform that action at this time.
0 commit comments