Struct datafusion_physical_plan::expressions::CastExpr

pub struct CastExpr {
    pub expr: Arc<dyn PhysicalExpr>,
    /* private fields */
}

CAST expression casts an expression to a specific data type and returns a runtime error on invalid cast

Fields

expr: Arc<dyn PhysicalExpr>

The expression to cast

Implementations

impl CastExpr

pub fn new( expr: Arc<dyn PhysicalExpr>, cast_type: DataType, cast_options: Option<CastOptions<'static>>, ) -> CastExpr

Create a new CastExpr

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

The expression to cast

pub fn cast_type(&self) -> &DataType

The data type to cast to

pub fn cast_options(&self) -> &CastOptions<'static>

The cast options

pub fn is_bigger_cast(&self, src: DataType) -> bool

Trait Implementations

impl Clone for CastExpr

fn clone(&self) -> CastExpr

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CastExpr

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

Formats the value using the given formatter.

impl Display for CastExpr

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

Formats the value using the given formatter.

impl PartialEq<dyn Any> for CastExpr

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl PhysicalExpr for CastExpr

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

Return a reference to Any that can be used for downcasting

fn get_properties( &self, children: &[ExprProperties], ) -> Result<ExprProperties, DataFusionError>

A CastExpr preserves the ordering of its child if the cast is done under the same datatype family.

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

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

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

Computes the output interval for the expression, given the input intervals.

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

Updates bounds for child expressions, given a known interval for this expression.

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