robin-sparkless 0.8.1

PySpark-like DataFrame API in Rust on Polars; no JVM.
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

"""Tests for issue #216: Date cast from datetime string.

Casting a string like '2025-01-01 10:30:00' to date must work (Spark accepts
datetime strings and truncates to date). Polars' default parser expects date-only format.
"""

import robin_sparkless as rs


def test_cast_datetime_string_to_date() -> None:
    """Exact scenario from #216: with_column('d', col('date_str').cast('date'))."""
    spark = rs.SparkSession.builder().app_name("test").get_or_create()
    df = spark._create_dataframe_from_rows(
        [{"date_str": "2025-01-01 10:30:00"}],
        [("date_str", "string")],
    )
    result = df.with_column("d", rs.col("date_str").cast("date"))
    rows = result.collect()
    assert len(rows) == 1
    assert rows[0]["date_str"] == "2025-01-01 10:30:00"
    assert rows[0]["d"] == "2025-01-01"


def test_cast_date_only_string_to_date() -> None:
    """Date-only string still works."""
    spark = rs.SparkSession.builder().app_name("test").get_or_create()
    df = spark._create_dataframe_from_rows(
        [{"date_str": "2025-01-01"}],
        [("date_str", "string")],
    )
    result = df.with_column("d", rs.col("date_str").cast("date"))
    rows = result.collect()
    assert len(rows) == 1
    assert rows[0]["d"] == "2025-01-01"


def test_try_cast_datetime_string_to_date_invalid_null() -> None:
    """try_cast: invalid string -> null."""
    spark = rs.SparkSession.builder().app_name("test").get_or_create()
    df = spark._create_dataframe_from_rows(
        [{"s": "2025-01-01 10:30:00"}, {"s": "not-a-date"}],
        [("s", "string")],
    )
    result = df.with_column("d", rs.try_cast(rs.col("s"), "date"))
    rows = result.collect()
    assert len(rows) == 2
    assert rows[0]["d"] == "2025-01-01"
    assert rows[1]["d"] is None