robin-sparkless 0.16.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

"""
Tests for #387: SparkSession.sparkContext (PySpark parity stub).
"""

from __future__ import annotations

import robin_sparkless as rs


def _spark() -> rs.SparkSession:
    return rs.SparkSession.builder().app_name("issue_387").get_or_create()


def test_spark_context_exists() -> None:
    """spark.sparkContext returns a SparkContext stub."""
    spark = _spark()
    ctx = spark.sparkContext
    assert ctx is not None


def test_spark_context_version() -> None:
    """SparkContext.version() returns a string."""
    spark = _spark()
    ctx = spark.sparkContext
    v = ctx.version()
    assert isinstance(v, str)
    assert len(v) >= 1