Expand description
Engine-agnostic types, traits, and expression IR re-exported from robin-sparkless-core.
Prefer these for engine-generic code and embeddings that should not depend on Polars.
Structs§
- Struct
Field - Struct
Type - When
Builder - When-then-otherwise builder.
- When
Then Builder
Enums§
- Data
Type - Engine
Error - Unified error type for robin-sparkless operations.
- ExprIr
- Expression IR: a single, serializable tree that backends convert to their native Expr.
- Join
Type - Literal
Value - Literal value in an expression (engine-agnostic).
Traits§
- Data
Frame Backend - Backend for DataFrame operations. All expression arguments use ExprIr.
Implementors can be downcast via
as_any()for backend-specific operations (e.g. join). - Data
Frame Reader Backend - Backend for reading files into a DataFrame.
- Grouped
Data Backend - Backend for GroupedData (result of group_by).
- Plan
Executor - Executes a logical plan (JSON list of ops) and returns a DataFrame.
- Spark
Session Backend - Backend for SparkSession: creates readers, tables, and DataFrames from data.
Functions§
- alias
- Alias an expression with a new output name.
- and_
- approx_
count_ distinct - between
- bool_
and - call
- Generic function call (for the long tail of functions).
- col
- Column reference.
- collect_
list - collect_
set - count
- count_
distinct - count_
if - eq
- every
- first
- ge
- gt
- is_in
- is_null
- kurtosis
- le
- lit_
bool - lit_f64
- lit_i32
- lit_i64
- lit_
null - lit_str
- lt
- max
- mean
- median
- min
- mode
- ne
- not_
- or_
- skewness
- std
- stddev
- stddev_
pop - stddev_
samp - sum
- try_avg
- try_sum
- var_pop
- var_
samp - variance
- when
- Start a when(condition).then(…).otherwise(…) chain.
Type Aliases§
- Collected
Rows - Rows as list of maps: column name -> JSON value. Used by bindings and collect.