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

Method scan

datafusion/catalog/src/empty.rs:66–78  ·  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

64 }
65
66 async fn scan(
67 &self,
68 _state: &dyn Session,
69 projection: Option<&Vec<usize>>,
70 _filters: &[Expr],
71 _limit: Option<usize>,
72 ) -> Result<Arc<dyn ExecutionPlan>> {
73 // even though there is no data, projections apply
74 let projected_schema = project_schema(&self.schema, projection)?;
75 Ok(Arc::new(
76 EmptyExec::new(projected_schema).with_partitions(self.partitions),
77 ))
78 }
79}

Callers

nothing calls this directly

Calls 3

project_schemaFunction · 0.85
newFunction · 0.85
with_partitionsMethod · 0.45

Tested by

no test coverage detected