Struct Column 

pub struct Column { /* private fields */ }

pyspark.sql.connect.column.Column

Represents a column in a DataFrame, built from an Expression. All operations return new Columns by composing expressions.

Implementations

impl Column

pub fn new(expr: Expression) -> Self

Create a Column from an Expression.

pub fn expression(&self) -> &Expression

Get the underlying Expression.

pub fn alias(self, name: &str) -> Column

Mirrors pyspark.sql.column.Column.alias.

pub fn alias_with_metadata( self, name: &str, metadata: BTreeMap<String, String>, ) -> Column

Column.alias(name, metadata=...) - attaches column metadata, serialized to a JSON map (matching the reference client’s json.dumps(metadata)).

pub fn name(self, name: &str) -> Column

Mirrors pyspark.sql.column.Column.name (alias for alias).

pub fn cast(self, to_type: DataType) -> Column

Mirrors pyspark.sql.column.Column.cast.

pub fn astype(self, to_type: DataType) -> Column

Mirrors pyspark.sql.column.Column.astype (alias for cast).

pub fn cast_str(self, type_name: &str) -> Column

Mirrors pyspark.sql.column.Column.cast with a DDL type string, e.g. col("x").cast("string") → cast { type_str: "string" }.

pub fn try_cast(self, to_type: DataType) -> Column

Mirrors pyspark.sql.column.Column.try_cast.

pub fn try_cast_str(self, type_name: &str) -> Column

Column.try_cast with a DDL type string.

pub fn is_null(self) -> Column

Mirrors pyspark.sql.column.Column.isNull.

pub fn is_not_null(self) -> Column

Mirrors pyspark.sql.column.Column.isNotNull.

pub fn substr(self, start: Column, length: Column) -> Column

Mirrors pyspark.sql.column.Column.substr.

pub fn like(self, pattern: &str) -> Column

Mirrors pyspark.sql.column.Column.like.

pub fn rlike(self, pattern: &str) -> Column

Mirrors pyspark.sql.column.Column.rlike.

pub fn contains(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.contains.

pub fn ilike(self, pattern: &str) -> Column

Mirrors pyspark.sql.column.Column.ilike (case-insensitive like).

pub fn is_nan(self) -> Column

Mirrors pyspark.sql.column.Column.isNaN.

pub fn eq_null_safe(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.eqNullSafe (null-safe equality <=>).

pub fn bitwise_and(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.bitwiseAND.

pub fn bitwise_or(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.bitwiseOR.

pub fn bitwise_xor(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.bitwiseXOR.

pub fn between(self, lower: Column, upper: Column) -> Column

Mirrors pyspark.sql.column.Column.between: (self >= lower) & (self <= upper).

pub fn isin<C: Into<Column>>( self, values: impl IntoIterator<Item = C>, ) -> Column

Mirrors pyspark.sql.column.Column.isin: membership test against the given values (pass literals via lit(..) or other columns).

pub fn with_field(self, field_name: &str, value: Column) -> Column

Mirrors pyspark.sql.column.Column.withField: add or replace a field in a struct-typed column.

pub fn drop_fields(self, field_names: Vec<&str>) -> Column

Mirrors pyspark.sql.column.Column.dropFields: drop one or more fields from a struct-typed column (chained UpdateFields, one per field).

pub fn startswith(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.startswith.

pub fn endswith(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.endswith.

pub fn asc(self) -> Column

Mirrors pyspark.sql.column.Column.asc.

pub fn asc_nulls_first(self) -> Column

Mirrors pyspark.sql.column.Column.asc_nulls_first.

pub fn asc_nulls_last(self) -> Column

Mirrors pyspark.sql.column.Column.asc_nulls_last.

pub fn desc(self) -> Column

Mirrors pyspark.sql.column.Column.desc.

pub fn desc_nulls_first(self) -> Column

Mirrors pyspark.sql.column.Column.desc_nulls_first.

pub fn desc_nulls_last(self) -> Column

Mirrors pyspark.sql.column.Column.desc_nulls_last.

pub fn when(self, condition: Column, value: Column) -> Column

Mirrors pyspark.sql.column.Column.when.

pub fn otherwise(self, value: Column) -> Column

Mirrors pyspark.sql.column.Column.otherwise.

pub fn get_field(self, name: &str) -> Column

Mirrors pyspark.sql.column.Column.getField - struct field access. Builds an UnresolvedExtractValue with the field name as a string literal.

pub fn get_item(self, key: Column) -> Column

Mirrors pyspark.sql.column.Column.__getitem__ / getItem - map/array/struct extraction. Builds an UnresolvedExtractValue.

pub fn to_proto(&self) -> Expression

Convert to proto expression.

pub fn over(self, window_spec: WindowSpec) -> Column

Mirrors pyspark.sql.column.Column.over - window function application.

pub fn eq(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__eq__.

pub fn ne(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__ne__.

pub fn gt(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__gt__.

pub fn lt(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__lt__.

pub fn ge(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__ge__.

pub fn le(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__le__.

pub fn add(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__add__.

pub fn sub(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__sub__.

pub fn mul(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__mul__.

pub fn div(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__truediv__.

pub fn modulo(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__mod__.

pub fn and(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__and__.

pub fn or(self, other: Column) -> Column

Mirrors pyspark.sql.column.Column.__or__.

pub fn not(self) -> Column

Mirrors pyspark.sql.column.Column.__invert__.

pub fn neg(self) -> Column

Mirrors pyspark.sql.column.Column.__neg__.

Trait Implementations

impl Add for Column

type Output = Column

The resulting type after applying the + operator.

fn add(self, other: Column) -> Column

Performs the + operation.

impl BitAnd for Column

type Output = Column

The resulting type after applying the & operator.

fn bitand(self, other: Column) -> Column

Performs the & operation.

impl BitOr for Column

type Output = Column

The resulting type after applying the | operator.

fn bitor(self, other: Column) -> Column

Performs the | operation.

impl Clone for Column

fn clone(&self) -> Column

Returns a duplicate 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 Div for Column

type Output = Column

The resulting type after applying the / operator.

fn div(self, other: Column) -> Column

Performs the / operation.

impl From<&String> for Column

fn from(name: &String) -> Column

Converts to this type from the input type.

impl From<&str> for Column

fn from(name: &str) -> Column

Converts to this type from the input type.

impl From<String> for Column

fn from(name: String) -> Column

Converts to this type from the input type.

impl Mul for Column

type Output = Column

The resulting type after applying the * operator.

fn mul(self, other: Column) -> Column

Performs the * operation.

impl Not for Column

type Output = Column

The resulting type after applying the ! operator.

fn not(self) -> Column

Performs the unary ! operation.

impl PartialEq for Column

fn eq(&self, other: &Column) -> bool

Equality operator ==.

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

Inequality operator !=.

impl Rem for Column

type Output = Column

The resulting type after applying the % operator.

fn rem(self, other: Column) -> Column

Performs the % operation.

impl StructuralPartialEq for Column

impl Sub for Column

type Output = Column

The resulting type after applying the - operator.

fn sub(self, other: Column) -> Column

Performs the - operation.