datafusion::physical_optimizer

Module sanity_checker

Source
Expand description

The SanityCheckPlan 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). In addition, it will check if all order and distribution requirements of a plan are satisfied by its children.

Structs§

Functions§

  • This function propagates finiteness information and rejects any plan with pipeline-breaking operators acting on infinite inputs.
  • Ensures that the plan is pipeline friendly and the order and distribution requirements from its children are satisfied.