File tree Expand file tree Collapse file tree 1 file changed +14
-0
lines changed
arrow-avro/src/reader/async_reader Expand file tree Collapse file tree 1 file changed +14
-0
lines changed Original file line number Diff line number Diff line change @@ -1300,6 +1300,20 @@ mod tests {
13001300 . await
13011301 . unwrap ( ) ;
13021302
1303+ assert_eq ! ( header_info. header_len( ) , 675 ) ;
1304+
1305+ let writer_schema = header_info. writer_schema ( ) . unwrap ( ) ;
1306+ let expected_avro_json: serde_json:: Value = serde_json:: from_str (
1307+ get_alltypes_schema ( )
1308+ . metadata ( )
1309+ . get ( SCHEMA_METADATA_KEY )
1310+ . unwrap ( ) ,
1311+ )
1312+ . unwrap ( ) ;
1313+ let actual_avro_json: serde_json:: Value =
1314+ serde_json:: from_str ( & writer_schema. json_string ) . unwrap ( ) ;
1315+ assert_eq ! ( actual_avro_json, expected_avro_json) ;
1316+
13031317 let reader = AsyncAvroFileReader :: builder ( file_reader, file_size, 1024 )
13041318 . build_with_header ( header_info)
13051319 . unwrap ( ) ;
You can’t perform that action at this time.
0 commit comments