datafusion_physical_optimizer::sanity_checker

Function check_finiteness_requirements

Source 
pub fn check_finiteness_requirements(
    input: Arc<dyn ExecutionPlan>,
    optimizer_options: &OptimizerOptions,
) -> Result<Transformed<Arc<dyn ExecutionPlan>>>
Expand description

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