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.