(&self, batch_size: usize)
| 637 | } |
| 638 | |
| 639 | fn with_batch_size(&self, batch_size: usize) -> Arc<dyn FileSource> { |
| 640 | let mut conf = self.clone(); |
| 641 | conf.batch_size = Some(batch_size); |
| 642 | Arc::new(conf) |
| 643 | } |
| 644 | |
| 645 | fn try_pushdown_projection( |
| 646 | &self, |