Struct datafusion::physical_plan::expressions::BinaryExpr

pub struct BinaryExpr { /* private fields */ }

Binary expression

Implementations

impl BinaryExpr

pub fn new(
    left: Arc<dyn PhysicalExpr + 'static>,
    op: Operator,
    right: Arc<dyn PhysicalExpr + 'static>
) -> BinaryExpr

Create new binary expression

pub fn left(&self) -> &Arc<dyn PhysicalExpr + 'static>

Get the left side of the binary expression

pub fn right(&self) -> &Arc<dyn PhysicalExpr + 'static>

Get the right side of the binary expression

pub fn op(&self) -> &Operator

Get the operator for this binary expression

Trait Implementations

impl Debug for BinaryExpr

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

Formats the value using the given formatter.

impl Display for BinaryExpr

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

Formats the value using the given formatter.

impl PartialEq<dyn Any + 'static> for BinaryExpr

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 BinaryExpr

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

Return a reference to Any that can be used for downcasting

fn boundaries(&self, context: &AnalysisContext) -> Option<ExprBoundaries>

Return the boundaries of this binary expression’s result.

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 + 'static>, Global>

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

fn with_new_children(
    self: Arc<BinaryExpr>,
    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.

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

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