Skip to main content

Crate robin_sparkless_expr

Crate robin_sparkless_expr 

Source
Expand description

Robin Sparkless expr: Column, expressions, functions, type coercion, UDF registry and UDFs.

Re-exports§

pub use column::Column;
pub use expression::column_to_expr;
pub use expression::lit_bool;
pub use expression::lit_f64;
pub use expression::lit_i32;
pub use expression::lit_i64;
pub use expression::lit_str;
pub use type_coercion::CompareOp;
pub use type_coercion::coerce_for_pyspark_comparison;
pub use type_coercion::coerce_for_pyspark_eq_null_safe;
pub use type_coercion::find_common_type;
pub use udf_context::get_thread_udf_context;
pub use udf_context::set_thread_udf_context;
pub use udf_registry::RustUdf;
pub use udf_registry::UdfRegistry;
pub use functions::*;

Modules§

column
expression
functions
type_coercion
udf_context
Thread-local UDF context for call_udf. Set by the main crate’s SparkSession.
udf_registry
UDF registry: session-scoped storage for Rust UDFs. PySpark parity: register_udf; call_udf resolves by name.
udfs
Helpers for element-wise UDFs used by map() expressions (soundex, levenshtein, crc32, xxhash64, array_flatten, array_repeat). These run at plan execution time when Polars invokes the closure.