(
&self,
state: &dyn Session,
projection: Option<&Vec<usize>>,
filters: &[Expr],
limit: Option<usize>,
)
| 458 | } |
| 459 | |
| 460 | async fn scan( |
| 461 | &self, |
| 462 | state: &dyn Session, |
| 463 | projection: Option<&Vec<usize>>, |
| 464 | filters: &[Expr], |
| 465 | limit: Option<usize>, |
| 466 | ) -> datafusion_common::Result<Arc<dyn ExecutionPlan>> { |
| 467 | let options = ScanArgs::default() |
| 468 | .with_projection(projection.map(|p| p.as_slice())) |
| 469 | .with_filters(Some(filters)) |
| 470 | .with_limit(limit); |
| 471 | Ok(self.scan_with_args(state, options).await?.into_inner()) |
| 472 | } |
| 473 | |
| 474 | async fn scan_with_args<'a>( |
| 475 | &self, |
nothing calls this directly
no test coverage detected