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

Method try_pushdown_sort

datafusion/datasource/src/source.rs:499–510  ·  view source on GitHub ↗
(
        &self,
        order: &[PhysicalSortExpr],
    )

Source from the content-addressed store, hash-verified

497 }
498
499 fn try_pushdown_sort(
500 &self,
501 order: &[PhysicalSortExpr],
502 ) -> Result<SortOrderPushdownResult<Arc<dyn ExecutionPlan>>> {
503 // Delegate to the data source and wrap result with DataSourceExec
504 self.data_source
505 .try_pushdown_sort(order)?
506 .try_map(|new_data_source| {
507 let new_exec = self.clone().with_data_source(new_data_source);
508 Ok(Arc::new(new_exec) as Arc<dyn ExecutionPlan>)
509 })
510 }
511
512 fn with_preserve_order(
513 &self,

Callers

nothing calls this directly

Calls 4

newFunction · 0.85
try_mapMethod · 0.80
with_data_sourceMethod · 0.80
cloneMethod · 0.45

Tested by

no test coverage detected