Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
datafusion::physical_optimizer::pipeline_fixer - Rust
[go: Go Back, main page]

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.