File tree Expand file tree Collapse file tree 1 file changed +24
-0
lines changed
arrow-avro/src/reader/async_reader Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Original file line number Diff line number Diff line change @@ -1286,6 +1286,30 @@ mod tests {
12861286 assert_eq ! ( batch. num_rows( ) , 8 ) ;
12871287 }
12881288
1289+ #[ tokio:: test]
1290+ async fn test_builder_with_header_info ( ) {
1291+ let file = arrow_test_data ( "avro/alltypes_plain.avro" ) ;
1292+ let store = Arc :: new ( LocalFileSystem :: new ( ) ) ;
1293+ let location = Path :: from_filesystem_path ( & file) . unwrap ( ) ;
1294+
1295+ let file_size = store. head ( & location) . await . unwrap ( ) . size ;
1296+
1297+ let mut file_reader = AvroObjectReader :: new ( store, location) ;
1298+
1299+ let header_info = read_header_info ( & mut file_reader, file_size, None )
1300+ . await
1301+ . unwrap ( ) ;
1302+
1303+ let reader = AsyncAvroFileReader :: builder ( file_reader, file_size, 1024 )
1304+ . build_with_header ( header_info)
1305+ . unwrap ( ) ;
1306+
1307+ let batches: Vec < RecordBatch > = reader. try_collect ( ) . await . unwrap ( ) ;
1308+
1309+ let batch = & batches[ 0 ] ;
1310+ assert_eq ! ( batch. num_rows( ) , 8 )
1311+ }
1312+
12891313 #[ tokio:: test]
12901314 async fn test_roundtrip_write_then_async_read ( ) {
12911315 use crate :: writer:: AvroWriter ;
You can’t perform that action at this time.
0 commit comments