robin_sparkless_polars/
lib.rs

1//! Robin Sparkless Polars: DataFrame, Session, Column, and expression layer (single crate that depends on Polars).
2
3#![allow(clippy::collapsible_if)]
4#![allow(clippy::let_and_return)]
5
6pub mod column;
7pub mod dataframe;
8pub mod engine_backend;
9pub mod error;
10pub mod expr_ir;
11pub mod expression;
12pub mod functions;
13pub mod plan;
14pub mod schema;
15pub(crate) mod schema_conv;
16pub mod session;
17pub mod traits;
18
19pub mod type_coercion;
20pub mod udf_context;
21pub mod udf_registry;
22pub mod udfs;
23
24#[cfg(feature = "delta")]
25pub mod delta;
26#[cfg(any(
27    feature = "jdbc",
28    feature = "jdbc_mysql",
29    feature = "jdbc_mariadb",
30    feature = "jdbc_mssql",
31    feature = "jdbc_oracle",
32    feature = "jdbc_db2",
33    feature = "sqlite"
34))]
35pub mod jdbc;
36#[cfg(feature = "sql")]
37pub mod sql;
38
39pub type Expr = polars::prelude::Expr;
40pub type LiteralValue = polars::prelude::LiteralValue;
41/// Re-export for root crate and API that returns Polars errors.
42pub use polars::error::PolarsError;
43/// Re-export for root DataFrame::from_polars.
44pub use polars::prelude::DataFrame as PlDataFrame;
45/// Re-export for root DataFrame::get_column_dtype return type.
46pub use polars::prelude::DataType as PlDataType;
47/// Re-export for root DataFrame::from_lazy.
48pub use polars::prelude::LazyFrame;
49/// Re-export for root SparkSession::register_udf.
50pub use polars::prelude::Series;
51
52pub use column::Column;
53pub use dataframe::{
54    CubeRollupData, DataFrame, GroupBySpec, GroupedData, JoinType, PivotedGroupedData, SaveMode,
55    SelectItem, WriteFormat, WriteMode, broadcast,
56};
57pub use error::{EngineError, polars_to_core_error};
58pub use expression::{column_to_expr, lit_bool, lit_f64, lit_i32, lit_i64, lit_str};
59pub use functions::*;
60pub use schema::{DataType, StructField, StructType, StructTypePolarsExt, schema_from_json};
61pub use session::{DataFrameReader, SparkSession, SparkSessionBuilder};
62pub use traits::{FromRobinDf, IntoRobinDf};
63pub use type_coercion::{
64    CompareOp, coerce_for_pyspark_comparison, coerce_for_pyspark_eq_null_safe, find_common_type,
65};
66pub use udf_context::{
67    clear_thread_udf_context, get_thread_session_time_zone, get_thread_udf_context,
68    set_thread_udf_context, set_thread_udf_context_with_tz, update_thread_session_time_zone,
69};
70pub use udf_registry::{RustUdf, UdfRegistry};
robin_sparkless_polars/lib.rs

robin_sparkless_polars/
lib.rs
