Struct datafusion_physical_expr::expressions::Column

pub struct Column { /* private fields */ }

Represents the column at a given index in a RecordBatch

Implementations

impl Column

pub fn new(name: &str, index: usize) -> Self

Create a new column expression

pub fn new_with_schema(name: &str, schema: &Schema) -> Result<Self>

Create a new column expression based on column name and schema

pub fn name(&self) -> &str

Get the column name

pub fn index(&self) -> usize

Get the column index

Trait Implementations

impl Clone for Column

fn clone(&self) -> Column

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Column

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

Formats the value using the given formatter.

impl Display for Column

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

Formats the value using the given formatter.

impl Hash for Column

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)where
    H: Hasher,
    Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq<Column> for Column

fn eq(&self, other: &Column) -> 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 PartialEq<dyn Any + 'static> for Column

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 Column

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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>

Decide whehter this expression is nullable, given the schema of the input

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

Evaluate the expression

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

Return the boundaries of this column, if known.

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

impl Eq for Column

impl StructuralEq for Column

impl StructuralPartialEq for Column