pub struct PipelineFixer {}
Expand description
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.
Implementations§
source§impl PipelineFixer
impl PipelineFixer
Trait Implementations§
source§impl Default for PipelineFixer
impl Default for PipelineFixer
source§fn default() -> PipelineFixer
fn default() -> PipelineFixer
Returns the “default value” for a type. Read more
source§impl PhysicalOptimizerRule for PipelineFixer
impl PhysicalOptimizerRule for PipelineFixer
source§fn optimize(
&self,
plan: Arc<dyn ExecutionPlan>,
_config: &ConfigOptions
) -> Result<Arc<dyn ExecutionPlan>>
fn optimize( &self, plan: Arc<dyn ExecutionPlan>, _config: &ConfigOptions ) -> Result<Arc<dyn ExecutionPlan>>
Rewrite
plan
to an optimized formsource§fn schema_check(&self) -> bool
fn schema_check(&self) -> bool
A flag to indicate whether the physical planner should valid the rule will not
change the schema of the plan after the rewriting.
Some of the optimization rules might change the nullable properties of the schema
and should disable the schema check.
Auto Trait Implementations§
impl RefUnwindSafe for PipelineFixer
impl Send for PipelineFixer
impl Sync for PipelineFixer
impl Unpin for PipelineFixer
impl UnwindSafe for PipelineFixer
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more