(mut array_reader: Box<dyn ArrayReader>)
| 823 | } |
| 824 | |
| 825 | fn bench_array_reader(mut array_reader: Box<dyn ArrayReader>) -> usize { |
| 826 | // test procedure: read data in batches of 8192 until no more data |
| 827 | let mut total_count = 0; |
| 828 | loop { |
| 829 | let array = array_reader.next_batch(BATCH_SIZE); |
| 830 | let array_len = array.unwrap().len(); |
| 831 | total_count += array_len; |
| 832 | if array_len < BATCH_SIZE { |
| 833 | break; |
| 834 | } |
| 835 | } |
| 836 | total_count |
| 837 | } |
| 838 | |
| 839 | fn bench_array_reader_skip(mut array_reader: Box<dyn ArrayReader>) -> usize { |
| 840 | // test procedure: read data in batches of 8192 until no more data |
no test coverage detected