()
| 1068 | |
| 1069 | #[tokio::test] |
| 1070 | async fn test_range_after_header() { |
| 1071 | let file = arrow_test_data("avro/alltypes_plain.avro"); |
| 1072 | let store = Arc::new(LocalFileSystem::new()); |
| 1073 | let location = Path::from_filesystem_path(&file).unwrap(); |
| 1074 | let meta = store.head(&location).await.unwrap(); |
| 1075 | |
| 1076 | let range = 100..meta.size; |
| 1077 | let schema = get_alltypes_schema(); |
| 1078 | let batches = read_async_file(&file, 1024, Some(range), Some(schema), None) |
| 1079 | .await |
| 1080 | .unwrap(); |
| 1081 | let batch = &batches[0]; |
| 1082 | |
| 1083 | assert!(batch.num_rows() > 0); |
| 1084 | } |
| 1085 | |
| 1086 | #[tokio::test] |
| 1087 | async fn test_range_no_sync_marker() { |
nothing calls this directly
no test coverage detected