Module datafusion::physical_optimizer::pipeline_checker
source · Expand description
The PipelineChecker rule ensures that a given plan can accommodate its infinite sources, if there are any. It will reject non-runnable query plans that use pipeline-breaking operators on infinite input(s).
Structs§
- The PipelineChecker rule rejects non-runnable query plans that use pipeline-breaking operators on infinite input(s).
Functions§
- This function propagates finiteness information and rejects any plan with pipeline-breaking operators acting on infinite inputs.