etlantic-pyspark 0.35.0

PySpark reference execution plugin for ETLantic.

etlantic-pyspark

PySpark reference execution plugin and portable transform compiler for ETLantic 0.34.

Note: PyPI Production/Stable classifiers describe this plugin package’s release channel. Core ETLantic 0.34 remains Beta for documented single-tenant pilots — classifiers are not an enterprise SLA.

Install

pip install etlantic-pyspark
# Optional Delta Lake support:
pip install "etlantic-pyspark[delta]"

Native Spark plugin

from etlantic import Profile

Profile(name="spark-local", spark_engine="pyspark")

Register @Transformation.implementation("pyspark") handlers that take Spark DataFrames (or lists of contract models) and return Spark DataFrames.

Native capabilities

• Lazy Spark region fusion with preserved logical identities
• Local Spark provider (local[*]) — secrets resolved only at session acquire
• Native-expression preference with UDF policy diagnostics
• Contract ↔ Spark schema mapping (lossy/unknown never guessed)
• Valid/invalid row separation
• Delta-compatible write intents (append/overwrite/merge) when Delta is enabled
• Structured Streaming foundation (experimental)

Portable transform compiler

Entry point: etlantic.transform_compilers → etlantic_pyspark:create_transform_compiler.

Claims portable-relational-kernel/1 and portable-relational/1. Lowers dtcs.transform-plan/2 to native Spark DataFrame/Column expressions. Automatic Python/Pandas UDF fallback is forbidden on the portable path (native UDF policy stays separate). Default CI uses sparkless; set SPARKLESS_TEST_MODE=pyspark for real JVM Catalyst checks.

Not included: managed cloud providers (Databricks/EMR/Connect).

Links

PySpark tutorial · Compatibility · Source · Issues