pub struct CoalesceBatches {}
Expand description
Optimizer rule that introduces CoalesceBatchesExec to avoid overhead with small batches that are produced by highly selective filters
Implementations§
Trait Implementations§
source§impl Default for CoalesceBatches
impl Default for CoalesceBatches
source§fn default() -> CoalesceBatches
fn default() -> CoalesceBatches
Returns the “default value” for a type. Read more
source§impl PhysicalOptimizerRule for CoalesceBatches
impl PhysicalOptimizerRule for CoalesceBatches
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 CoalesceBatches
impl Send for CoalesceBatches
impl Sync for CoalesceBatches
impl Unpin for CoalesceBatches
impl UnwindSafe for CoalesceBatches
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