Module datafusion::physical_optimizer::pipeline_fixer

source ·
Expand description

The PipelineFixer rule tries to modify a given plan so that it can accommodate its infinite sources, if there are any. In other words, it tries to obtain a runnable query (with the given infinite sources) from an non-runnable query by transforming pipeline-breaking operations to pipeline-friendly ones. If this can not be done, the rule emits a diagnostic error message.

Structs

  • PipelineFixer
    The PipelineFixer rule tries to modify a given plan so that it can accommodate its infinite sources, if there are any. If this is not possible, the rule emits a diagnostic error message.