MCPcopy Create free account
hub / github.com/apache/datafusion / scan

Method scan

datafusion/catalog-listing/src/table.rs:460–472  ·  view source on GitHub ↗
(
        &self,
        state: &dyn Session,
        projection: Option<&Vec<usize>>,
        filters: &[Expr],
        limit: Option<usize>,
    )

Source from the content-addressed store, hash-verified

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,

Callers

nothing calls this directly

Calls 6

with_filtersMethod · 0.80
with_limitMethod · 0.45
with_projectionMethod · 0.45
mapMethod · 0.45
into_innerMethod · 0.45
scan_with_argsMethod · 0.45

Tested by

no test coverage detected