robin-sparkless 0.11.2

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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

"""Verify that code examples from the documentation run correctly."""

import pytest
import robin_sparkless as rs


def test_user_guide_filter() -> None:
    """USER_GUIDE: Filter example."""
    spark = rs.SparkSession.builder().app_name("doc_test").get_or_create()
    df = spark.createDataFrame(
        [(1, 25, "Alice"), (2, 30, "Bob"), (3, 35, "Charlie")], ["id", "age", "name"]
    )
    adults = df.filter(rs.col("age") > rs.lit(25))
    rows = adults.collect()
    assert len(rows) == 2
    assert rows[0]["age"] == 30
    assert rows[1]["age"] == 35


def test_user_guide_when_then_otherwise() -> None:
    """USER_GUIDE: when/then/otherwise nested example."""
    spark = rs.SparkSession.builder().app_name("doc_test").get_or_create()
    df = spark.createDataFrame(
        [(1, 10, "a"), (2, 25, "b"), (3, 70, "c")], ["id", "age", "name"]
    )
    df2 = df.with_column(
        "category",
        rs.when(rs.col("age") >= 65)
        .then(rs.lit("senior"))
        .otherwise(
            rs.when(rs.col("age") >= 18)
            .then(rs.lit("adult"))
            .otherwise(rs.lit("minor"))
        ),
    )
    rows = df2.collect()
    assert len(rows) == 3
    assert rows[0]["category"] == "minor"
    assert rows[1]["category"] == "adult"
    assert rows[2]["category"] == "senior"


def test_user_guide_na_fill_drop() -> None:
    """USER_GUIDE: na().fill() and na().drop()."""
    spark = rs.SparkSession.builder().app_name("doc_test").get_or_create()
    df = spark.createDataFrame(
        [{"x": 1, "y": None}, {"x": 2, "y": 5}, {"x": None, "y": 7}],
        [("x", "bigint"), ("y", "bigint")],
    )
    filled = df.na().fill(rs.lit(0))
    rows = filled.collect()
    assert rows[0]["y"] == 0
    assert rows[2]["x"] == 0
    dropped = df.na().drop(subset=["x"])  # Drop rows with null in "x" (removes row 2)
    assert len(dropped.collect()) == 2


def test_user_guide_create_dataframe_from_rows() -> None:
    """USER_GUIDE: _create_dataframe_from_rows."""
    spark = rs.SparkSession.builder().app_name("doc_test").get_or_create()
    schema = [("id", "bigint"), ("name", "string"), ("score", "double")]
    rows = [
        {"id": 1, "name": "Alice", "score": 95.5},
        {"id": 2, "name": "Bob", "score": 87.0},
    ]
    df = spark.createDataFrame(rows, schema)
    result = df.collect()
    assert len(result) == 2
    assert result[0]["name"] == "Alice"
    assert result[1]["score"] == 87.0


def test_user_guide_persistence_temp_view() -> None:
    """USER_GUIDE: createOrReplaceTempView."""
    spark = rs.SparkSession.builder().app_name("doc_test").get_or_create()
    df = spark.createDataFrame([(1, 25, "Alice")], ["id", "age", "name"])
    try:
        df.createOrReplaceTempView("people")
        result = spark.sql("SELECT name, age FROM people WHERE age > 20")
    except AttributeError:
        pytest.skip("sql feature not built")
    rows = result.collect()
    assert len(rows) == 1
    assert rows[0]["name"] == "Alice"


def test_readme_python_quickstart() -> None:
    """README: Python quick start example (runs both main README and README-Python)."""
    spark = rs.SparkSession.builder().app_name("demo").get_or_create()
    df = spark.createDataFrame(
        [(1, 25, "Alice"), (2, 30, "Bob"), (3, 35, "Charlie")],
        ["id", "age", "name"],
    )
    filtered = df.filter(rs.col("age") > rs.lit(26))
    rows = filtered.collect()
    assert rows == [
        {"id": 2, "age": 30, "name": "Bob"},
        {"id": 3, "age": 35, "name": "Charlie"},
    ]