Module sanity_checker 

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

SanityCheckPlan

The SanityCheckPlan rule rejects the following query plans:

Functions

check_finiteness_requirements

This function propagates finiteness information and rejects any plan with pipeline-breaking operators acting on infinite inputs.

check_plan_sanity

Ensures that the plan is pipeline friendly and the order and distribution requirements from its children are satisfied.

is_prunable 🔒

This function returns whether a given symmetric hash join is amenable to data pruning. For this to be possible, it needs to have a filter where all involved PhysicalExprs, Operators and data types support interval calculations.