Struct deltalake::datafusion::physical_expr::expressions::NegativeExpr

pub struct NegativeExpr { /* private fields */ }

Negative expression

Implementations

impl NegativeExpr

pub fn new(arg: Arc<dyn PhysicalExpr>) -> NegativeExpr

Create new not expression

pub fn arg(&self) -> &Arc<dyn PhysicalExpr>

Get the input expression

Trait Implementations

impl Debug for NegativeExpr

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

Formats the value using the given formatter.

impl Display for NegativeExpr

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

Formats the value using the given formatter.

impl Hash for NegativeExpr

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq<dyn Any> for NegativeExpr

fn eq(&self, other: &(dyn Any + 'static)) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PhysicalExpr for NegativeExpr

fn as_any(&self) -> &(dyn Any + 'static)

Return a reference to Any that can be used for downcasting

fn evaluate_bounds( &self, children: &[&Interval] ) -> Result<Interval, DataFusionError>

Given the child interval of a NegativeExpr, it calculates the NegativeExpr’s interval. It replaces the upper and lower bounds after multiplying them with -1. Ex: (a, b] => [-b, -a)

fn propagate_constraints( &self, interval: &Interval, children: &[&Interval] ) -> Result<Option<Vec<Interval>>, DataFusionError>

Returns a new Interval of a NegativeExpr that has the existing interval given that given the input interval is known to be children.

fn get_ordering(&self, children: &[SortProperties]) -> SortProperties

The ordering of a NegativeExpr is simply the reverse of its child.

fn data_type(&self, input_schema: &Schema) -> Result<DataType, DataFusionError>

Get the data type of this expression, given the schema of the input

fn nullable(&self, input_schema: &Schema) -> Result<bool, DataFusionError>

Determine whether this expression is nullable, given the schema of the input

fn evaluate( &self, batch: &RecordBatch ) -> Result<ColumnarValue, DataFusionError>

Evaluate an expression against a RecordBatch

fn children(&self) -> Vec<Arc<dyn PhysicalExpr>>

Get a list of child PhysicalExpr that provide the input for this expr.

fn with_new_children( self: Arc<NegativeExpr>, children: Vec<Arc<dyn PhysicalExpr>> ) -> Result<Arc<dyn PhysicalExpr>, DataFusionError>

Returns a new PhysicalExpr where all children were replaced by new exprs.

fn dyn_hash(&self, state: &mut dyn Hasher)

Update the hash state with this expression requirements from Hash.

fn evaluate_selection( &self, batch: &RecordBatch, selection: &BooleanArray ) -> Result<ColumnarValue, DataFusionError>

Evaluate an expression against a RecordBatch after first applying a validity array