(&self, batch_size: usize)
| 204 | } |
| 205 | |
| 206 | fn with_batch_size(&self, batch_size: usize) -> Arc<dyn FileSource> { |
| 207 | let mut conf = self.clone(); |
| 208 | conf.batch_size = Some(batch_size); |
| 209 | Arc::new(conf) |
| 210 | } |
| 211 | |
| 212 | fn try_pushdown_projection( |
| 213 | &self, |