(
&self,
state: &dyn Session,
projection: Option<&Vec<usize>>,
filters: &[Expr],
limit: Option<usize>,
)
| 77 | } |
| 78 | |
| 79 | async fn scan( |
| 80 | &self, |
| 81 | state: &dyn Session, |
| 82 | projection: Option<&Vec<usize>>, |
| 83 | filters: &[Expr], |
| 84 | limit: Option<usize>, |
| 85 | ) -> Result<Arc<dyn ExecutionPlan>> { |
| 86 | let options = ScanArgs::default() |
| 87 | .with_projection(projection.map(|p| p.as_slice())) |
| 88 | .with_filters(Some(filters)) |
| 89 | .with_limit(limit); |
| 90 | Ok(self.scan_with_args(state, options).await?.into_inner()) |
| 91 | } |
| 92 | |
| 93 | async fn scan_with_args<'a>( |
| 94 | &self, |
nothing calls this directly
no test coverage detected