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.