Struct datafusion_physical_expr::expressions::DateTimeIntervalExpr

pub struct DateTimeIntervalExpr { /* private fields */ }

Perform DATE/TIME/TIMESTAMP +/ INTERVAL math

Implementations

impl DateTimeIntervalExpr

pub fn try_new( lhs: Arc<dyn PhysicalExpr>, op: Operator, rhs: Arc<dyn PhysicalExpr>, input_schema: &Schema ) -> Result<Self>

Create a new instance of DateIntervalExpr

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

Get the left-hand side expression

pub fn op(&self) -> &Operator

Get the operator

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

Get the right-hand side expression

Trait Implementations

impl Debug for DateTimeIntervalExpr

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

Formats the value using the given formatter.

impl Display for DateTimeIntervalExpr

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

Formats the value using the given formatter.

impl PartialEq<dyn Any + 'static> for DateTimeIntervalExpr

fn eq(&self, other: &dyn Any) -> 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 DateTimeIntervalExpr

fn as_any(&self) -> &dyn Any

Returns the physical expression as Any so that it can be downcast to a specific implementation.

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

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

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

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

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

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<Self>, children: Vec<Arc<dyn PhysicalExpr>> ) -> Result<Arc<dyn PhysicalExpr>>

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

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

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

fn analyze(&self, context: AnalysisContext) -> AnalysisContext

Return the boundaries of this expression. This method (and all the related APIs) are experimental and subject to change.

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

Computes bounds for the expression using interval arithmetic.

fn propagate_constraints( &self, _interval: &Interval, _children: &[&Interval] ) -> Result<Vec<Option<Interval>>>

Updates/shrinks bounds for the expression using interval arithmetic. If constraint propagation reveals an infeasibility, returns None for the child causing infeasibility. If none of the children intervals change, may return an empty vector instead of cloning children.