(
name: &'_ str,
projection: Option<Vec<usize>>,
)
| 260 | use std::io::BufReader; |
| 261 | |
| 262 | fn build_reader( |
| 263 | name: &'_ str, |
| 264 | projection: Option<Vec<usize>>, |
| 265 | ) -> Reader<BufReader<File>> { |
| 266 | let testdata = datafusion_common::test_util::arrow_test_data(); |
| 267 | let filename = format!("{testdata}/avro/{name}"); |
| 268 | let mut builder = ReaderBuilder::new().with_batch_size(64); |
| 269 | if let Some(proj) = projection { |
| 270 | builder = builder.with_projection(proj); |
| 271 | } |
| 272 | builder |
| 273 | .build(BufReader::new(File::open(filename).unwrap())) |
| 274 | .unwrap() |
| 275 | } |
| 276 | |
| 277 | fn get_col<'a, T: 'static>( |
| 278 | batch: &'a RecordBatch, |
searching dependent graphs…