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

Method try_pushdown_sort

datafusion/physical-plan/src/buffer.rs:281–290  ·  view source on GitHub ↗
(
        &self,
        order: &[PhysicalSortExpr],
    )

Source from the content-addressed store, hash-verified

279 }
280
281 fn try_pushdown_sort(
282 &self,
283 order: &[PhysicalSortExpr],
284 ) -> Result<SortOrderPushdownResult<Arc<dyn ExecutionPlan>>> {
285 // CoalesceBatchesExec is transparent for sort ordering - it preserves order
286 // Delegate to the child and wrap with a new CoalesceBatchesExec
287 self.input.try_pushdown_sort(order)?.try_map(|new_input| {
288 Ok(Arc::new(Self::new(new_input, self.capacity)) as Arc<dyn ExecutionPlan>)
289 })
290 }
291}
292
293/// Represents anything that occupies a capacity in a [MemoryBufferedStream].

Callers

nothing calls this directly

Calls 2

newFunction · 0.85
try_mapMethod · 0.80

Tested by

no test coverage detected