Function datafusion::physical_optimizer::pipeline_checker::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.