(
&self,
state: &dyn Session,
projection: Option<&Vec<usize>>,
_filters: &[Expr],
_limit: Option<usize>,
)
| 478 | } |
| 479 | |
| 480 | async fn scan( |
| 481 | &self, |
| 482 | state: &dyn Session, |
| 483 | projection: Option<&Vec<usize>>, |
| 484 | _filters: &[Expr], |
| 485 | _limit: Option<usize>, |
| 486 | ) -> Result<Arc<dyn ExecutionPlan>> { |
| 487 | let batch_size = state.config_options().execution.batch_size; |
| 488 | let generator = self.as_generator(batch_size)?; |
| 489 | let mut exec = LazyMemoryExec::try_new(self.schema(), vec![generator])? |
| 490 | .with_projection(projection.cloned()); |
| 491 | |
| 492 | if let Some(ordering) = self.output_ordering(exec.schema().as_ref()) { |
| 493 | exec.add_ordering([ordering]); |
| 494 | } |
| 495 | |
| 496 | Ok(Arc::new(exec)) |
| 497 | } |
| 498 | } |
| 499 | |
| 500 | #[derive(Debug)] |
no test coverage detected