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

Method compute_properties

datafusion/datasource/src/source.rs:582–590  ·  view source on GitHub ↗
(data_source: &Arc<dyn DataSource>)

Source from the content-addressed store, hash-verified

580 }
581
582 fn compute_properties(data_source: &Arc<dyn DataSource>) -> PlanProperties {
583 PlanProperties::new(
584 data_source.eq_properties(),
585 data_source.output_partitioning(),
586 EmissionType::Incremental,
587 Boundedness::Bounded,
588 )
589 .with_scheduling_type(data_source.scheduling_type())
590 }
591
592 /// Downcast the `DataSourceExec`'s `data_source` to a specific file source
593 ///

Callers

nothing calls this directly

Calls 5

newFunction · 0.85
with_scheduling_typeMethod · 0.80
eq_propertiesMethod · 0.45
output_partitioningMethod · 0.45
scheduling_typeMethod · 0.45

Tested by

no test coverage detected