Struct datafusion::physical_plan::expressions::TryCastExpr
source · pub struct TryCastExpr { /* private fields */ }
Expand description
TRY_CAST expression casts an expression to a specific data type and retuns NULL on invalid cast
Implementations§
source§impl TryCastExpr
impl TryCastExpr
sourcepub fn new(
expr: Arc<dyn PhysicalExpr + 'static>,
cast_type: DataType
) -> TryCastExpr
pub fn new(
expr: Arc<dyn PhysicalExpr + 'static>,
cast_type: DataType
) -> TryCastExpr
Create a new CastExpr
sourcepub fn expr(&self) -> &Arc<dyn PhysicalExpr + 'static>
pub fn expr(&self) -> &Arc<dyn PhysicalExpr + 'static>
The expression to cast
Trait Implementations§
source§impl Debug for TryCastExpr
impl Debug for TryCastExpr
source§impl Display for TryCastExpr
impl Display for TryCastExpr
source§impl PartialEq<dyn Any + 'static> for TryCastExpr
impl PartialEq<dyn Any + 'static> for TryCastExpr
source§impl PhysicalExpr for TryCastExpr
impl PhysicalExpr for TryCastExpr
source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Return a reference to Any that can be used for downcasting
source§fn data_type(&self, _input_schema: &Schema) -> Result<DataType, DataFusionError>
fn data_type(&self, _input_schema: &Schema) -> Result<DataType, DataFusionError>
Get the data type of this expression, given the schema of the input
source§fn nullable(&self, _input_schema: &Schema) -> Result<bool, DataFusionError>
fn nullable(&self, _input_schema: &Schema) -> Result<bool, DataFusionError>
Determine whether this expression is nullable, given the schema of the input
source§fn evaluate(&self, batch: &RecordBatch) -> Result<ColumnarValue, DataFusionError>
fn evaluate(&self, batch: &RecordBatch) -> Result<ColumnarValue, DataFusionError>
Evaluate an expression against a RecordBatch
source§fn children(&self) -> Vec<Arc<dyn PhysicalExpr + 'static>, Global> ⓘ
fn children(&self) -> Vec<Arc<dyn PhysicalExpr + 'static>, Global> ⓘ
Get a list of child PhysicalExpr that provide the input for this expr.
source§fn with_new_children(
self: Arc<TryCastExpr>,
children: Vec<Arc<dyn PhysicalExpr + 'static>, Global>
) -> Result<Arc<dyn PhysicalExpr + 'static>, DataFusionError>
fn with_new_children(
self: Arc<TryCastExpr>,
children: Vec<Arc<dyn PhysicalExpr + 'static>, Global>
) -> Result<Arc<dyn PhysicalExpr + 'static>, DataFusionError>
Returns a new PhysicalExpr where all children were replaced by new exprs.
source§fn evaluate_selection(
&self,
batch: &RecordBatch,
selection: &BooleanArray
) -> Result<ColumnarValue, DataFusionError>
fn evaluate_selection(
&self,
batch: &RecordBatch,
selection: &BooleanArray
) -> Result<ColumnarValue, DataFusionError>
Evaluate an expression against a RecordBatch after first applying a
validity array Read more
source§fn boundaries(&self, context: &AnalysisContext) -> Option<ExprBoundaries>
fn boundaries(&self, context: &AnalysisContext) -> Option<ExprBoundaries>
Return the boundaries of this expression. This method (and all the
related APIs) are experimental and subject to change. Read more