robin-sparkless-core 4.9.0

Shared types, config, and error for robin-sparkless (no Polars).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

//! PySpark 3.5 vs 4.0 JDBC type-mapping profile helpers (see docs/PYSPARK_4_PARITY_PLAN.md ยง5.4).

use crate::runtime_config::{PysparkCompat, SessionRuntimeConfig};

/// True when `compat=4.0` and legacy restore flags are off (PySpark 4 JDBC semantics).
pub fn jdbc_v4_type_mappings(cfg: &SessionRuntimeConfig) -> bool {
    cfg.pyspark_compat == PysparkCompat::V4_0
        && !cfg.legacy_postgres_datetime_mapping
        && !cfg.legacy_mysql_datetime_mapping
        && !cfg.legacy_oracle_timestamp_mapping
        && !cfg.legacy_mssqlserver_datetime_mapping
        && !cfg.legacy_db2_datetime_mapping
}

pub fn postgres_v4_datetime_mapping(cfg: &SessionRuntimeConfig) -> bool {
    cfg.pyspark_compat == PysparkCompat::V4_0 && !cfg.legacy_postgres_datetime_mapping
}

pub fn mysql_v4_type_mapping(cfg: &SessionRuntimeConfig) -> bool {
    cfg.pyspark_compat == PysparkCompat::V4_0 && !cfg.legacy_mysql_datetime_mapping
}

pub fn oracle_v4_timestamp_mapping(cfg: &SessionRuntimeConfig) -> bool {
    cfg.pyspark_compat == PysparkCompat::V4_0 && !cfg.legacy_oracle_timestamp_mapping
}

pub fn mssql_v4_type_mapping(cfg: &SessionRuntimeConfig) -> bool {
    cfg.pyspark_compat == PysparkCompat::V4_0 && !cfg.legacy_mssqlserver_datetime_mapping
}

pub fn db2_v4_type_mapping(cfg: &SessionRuntimeConfig) -> bool {
    cfg.pyspark_compat == PysparkCompat::V4_0 && !cfg.legacy_db2_datetime_mapping
}