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

Method scan

datafusion/functions-table/src/generate_series.rs:480–497  ·  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

478 }
479
480 async fn scan(
481 &self,
482 state: &dyn Session,
483 projection: Option<&Vec<usize>>,
484 _filters: &[Expr],
485 _limit: Option<usize>,
486 ) -> Result<Arc<dyn ExecutionPlan>> {
487 let batch_size = state.config_options().execution.batch_size;
488 let generator = self.as_generator(batch_size)?;
489 let mut exec = LazyMemoryExec::try_new(self.schema(), vec![generator])?
490 .with_projection(projection.cloned());
491
492 if let Some(ordering) = self.output_ordering(exec.schema().as_ref()) {
493 exec.add_ordering([ordering]);
494 }
495
496 Ok(Arc::new(exec))
497 }
498}
499
500#[derive(Debug)]

Callers 3

criterion_benchmarkFunction · 0.45

Calls 9

newFunction · 0.85
as_generatorMethod · 0.80
config_optionsMethod · 0.45
with_projectionMethod · 0.45
schemaMethod · 0.45
clonedMethod · 0.45
output_orderingMethod · 0.45
as_refMethod · 0.45
add_orderingMethod · 0.45

Tested by

no test coverage detected