robin-sparkless 4.4.0

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

"""Tests for issue #396: selectExpr and expr() SQL string."""

from __future__ import annotations

from sparkless.testing import get_imports


_imports = get_imports()
SparkSession = _imports.SparkSession
F = _imports.F


def test_select_expr_sql_expressions() -> None:
    """selectExpr accepts SQL expressions (e.g. 'Name', 'upper(Name) as u')."""
    spark = SparkSession.builder.appName("issue_396").getOrCreate()
    df = spark.createDataFrame([("Alice",), ("Bob",)], ["Name"])
    out = df.selectExpr("Name", "upper(Name) as u")
    rows = out.collect()
    assert len(rows) == 2
    assert "Name" in rows[0] and "u" in rows[0]
    assert rows[0]["u"] == "ALICE"
    assert rows[1]["u"] == "BOB"


def test_expr_in_select() -> None:
    """expr(sql_string) returns ExprStr that resolves in select()."""
    spark = SparkSession.builder.appName("issue_396").getOrCreate()
    df = spark.createDataFrame([("a",), ("b",)], ["x"])
    out = df.select(F.expr("upper(x) as up"))
    rows = out.collect()
    assert len(rows) == 2
    assert rows[0]["up"] == "A"
    assert rows[1]["up"] == "B"


def test_select_expr_column_name_and_alias() -> None:
    """selectExpr with simple column and 'col as alias'."""
    spark = SparkSession.builder.appName("issue_396").getOrCreate()
    df = spark.createDataFrame([(1, 2)], ["a", "b"])
    out = df.selectExpr("a", "b as b_col")
    row = out.collect()[0]
    assert row["a"] == 1
    assert row["b_col"] == 2