etlantic-pyspark
PySpark reference execution plugin and portable transform compiler for ETLantic 0.52.
Note: This plugin and ETLantic core use Beta classifiers 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]"
Portable transform compiler
from etlantic import Profile
Profile(
name="spark-local",
spark_engine="pyspark",
portable_transform_policy="require",
)
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. This is
the recommended transformation path and remains eligible for adaptive
execution. Automatic Python/Pandas UDF fallback is forbidden.
Native Spark plugin
Register @Transformation.implementation("pyspark") handlers only for Spark
behavior outside the portable compiler's claims. They take Spark DataFrames
(or lists of contract models), return Spark DataFrames, pin the step to
PySpark, and are not eligible for adaptive execution.
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)
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
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file etlantic_pyspark-0.52.0.tar.gz.
File metadata
- Download URL: etlantic_pyspark-0.52.0.tar.gz
- Upload date:
- Size: 22.5 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.12.0 {"installer":{"name":"uv","version":"0.12.0","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
06785488394faf101f014225c2dae71c1cefaab46d58ad17a61d09490188426a
|
|
| MD5 |
2527626022dec3923106f858e81b9282
|
|
| BLAKE2b-256 |
08441194e11bfa7ed727938cc51ecde1480b8d434d0494ee4daf81d82c673a91
|
File details
Details for the file etlantic_pyspark-0.52.0-py3-none-any.whl.
File metadata
- Download URL: etlantic_pyspark-0.52.0-py3-none-any.whl
- Upload date:
- Size: 26.2 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.12.0 {"installer":{"name":"uv","version":"0.12.0","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
c3fbb2181c884ec3b9f6ace1cd859aa52364935b6e3f8099fdeb9f34403dcde9
|
|
| MD5 |
52095b92251b5509ec4797b0893c1f92
|
|
| BLAKE2b-256 |
5c967575477ad322d04bc96e85a3a1b186282bb7507935a35be02b31fb520cfe
|
