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

Method scan

datafusion/catalog/src/cte_worktable.rs:79–91  ·  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

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,

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