Skip to main content

Module extractor

Module extractor 

Source
Expand description

Pipeline extraction from DataFusion logical plans.

PipelineExtractor walks a [LogicalPlan] top-down, decomposing it into compilable Pipeline segments separated by PipelineBreakers (stateful operators like aggregations, sorts, and joins).

Structsยง

ExtractedPlan
The result of extracting pipelines from a logical plan.
PipelineExtractor
Extracts compilable pipelines from DataFusion logical plans.