Struct ArrowMetalRule 

pub struct ArrowMetalRule { /* private fields */ }

Replaces SortExec (+ its SortPreservingMergeExec), hash AggregateExec (a Single node, or a Final/Partial pair) and FilterExec with MetalExec when ArrowMetal gives the same answer and the input is big enough. Cloning shares the report.

Implementations

impl ArrowMetalRule

pub fn new(config: ArrowMetalConfig) -> Self

A rule with this config and an empty report.

pub fn config(&self) -> &ArrowMetalConfig

The config the rule was made with.

pub fn report(&self) -> Report

A snapshot of the decisions of the last report_plans plans (plan time, run-time choices and runtime fallbacks).

pub fn clear_report(&self)

Empties the report.

Trait Implementations

impl Clone for ArrowMetalRule

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ArrowMetalRule

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PhysicalOptimizerRule for ArrowMetalRule

fn optimize( &self, plan: Arc<dyn ExecutionPlan>, config: &ConfigOptions, ) -> Result<Arc<dyn ExecutionPlan>>

Rewrite plan to an optimized form.

fn name(&self) -> &str

A human readable name for this optimizer rule

fn schema_check(&self) -> bool

A flag to indicate whether the physical planner should validate that 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.

fn optimize_with_context( &self, plan: Arc<dyn ExecutionPlan>, context: &dyn PhysicalOptimizerContext, ) -> Result<Arc<dyn ExecutionPlan>, DataFusionError>

Rewrite plan with access to extended context (statistics registry, etc.).