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

Function current_planner_continuation

datafusion/datasource/src/morsel/mocks.rs:485–502  ·  view source on GitHub ↗

Rebuilds the mock planner continuation after one step completes.

(
    observer: MorselObserver,
    planner_name: String,
    steps: VecDeque<PlannerStep>,
)

Source from the content-addressed store, hash-verified

483
484/// Rebuilds the mock planner continuation after one step completes.
485fn current_planner_continuation(
486 observer: MorselObserver,
487 planner_name: String,
488 steps: VecDeque<PlannerStep>,
489) -> Vec<Box<dyn MorselPlanner>> {
490 let only_none_remaining =
491 matches!(steps.front(), Some(PlannerStep::None)) && steps.len() == 1;
492
493 if steps.is_empty() || only_none_remaining {
494 Vec::new()
495 } else {
496 vec![Box::new(MockMorselPlanner {
497 observer,
498 planner_name,
499 steps,
500 }) as Box<dyn MorselPlanner>]
501 }
502}
503
504/// Create any child planners produced by this planning step.
505fn child_planners(

Callers 1

planMethod · 0.85

Calls 3

newFunction · 0.85
lenMethod · 0.45
is_emptyMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…