pub struct UnwrapCastInComparison {}
Expand description

UnwrapCastInComparison attempts to remove casts from comparisons to literals (ScalarValues) by applying the casts to the literals if possible. It is inspired by the optimizer rule UnwrapCastInBinaryComparison of Spark.

Removing casts often improves performance because:

  1. The cast is done once (to the literal) rather than to every value
  2. Can enable other optimizations such as predicate pushdown that don’t support casting

The rule is applied to expressions of the following forms:

  1. cast(left_expr as data_type) comparison_op literal_expr
  2. literal_expr comparison_op cast(left_expr as data_type)
  3. cast(literal_expr) IN (expr1, expr2, ...)
  4. literal_expr IN (cast(expr1) , cast(expr2), ...)

If the expression matches one of the forms above, the rule will ensure the value of literal is in range(min, max) of the expr’s data_type, and if the scalar is within range, the literal will be casted to the data type of expr on the other side, and the cast will be removed from the other side.

Example

If the DataType of c1 is INT32. Given the filter

Filter: cast(c1 as INT64) > INT64(10)`

This rule will remove the cast and rewrite the expression to:

Filter: c1 > INT32(10)

Implementations§

Trait Implementations§

source§

impl Default for UnwrapCastInComparison

source§

fn default() -> UnwrapCastInComparison

Returns the “default value” for a type. Read more
source§

impl OptimizerRule for UnwrapCastInComparison

source§

fn try_optimize( &self, plan: &LogicalPlan, _config: &dyn OptimizerConfig ) -> Result<Option<LogicalPlan>, DataFusionError>

Try and rewrite plan to an optimized form, returning None if the plan cannot be optimized by this rule.
source§

fn name(&self) -> &str

A human readable name for this optimizer rule
source§

fn apply_order(&self) -> Option<ApplyOrder>

How should the rule be applied by the optimizer? See comments on ApplyOrder for details. Read more

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> Allocation for Twhere T: RefUnwindSafe + Send + Sync,