etlantic-pyspark
PySpark reference execution plugin and portable transform compiler for ETLantic 0.57.
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
Metadata
1 maintainer
Release files for etlantic-pyspark 0.57.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| etlantic_pyspark-0.57.0.tar.gz | 22.5 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| etlantic_pyspark-0.57.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 48.8 kB
Release files / etlantic_pyspark-0.57.0.tar.gz
| Download URL | etlantic_pyspark-0.57.0.tar.gz |
|---|---|
| Size | 22.5 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
cfb7909382a4df23ff2a74172a63a43acab7777764c6a3b10623dbe2dddbcbeb
|
|
BLAKE2b-256 checksum How to use checksums |
8b3a9dfd2566496f6934263ef22a618c7dd4d512be8c2bb894f22edff4d82fbe
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is 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}
|
Release files / etlantic_pyspark-0.57.0-py3-none-any.whl
| Download URL | etlantic_pyspark-0.57.0-py3-none-any.whl |
|---|---|
| Size | 26.3 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
0754a91613571fe53d5e52837551abecdaeace7ffd09d0b63b775c703db6d99b
|
|
BLAKE2b-256 checksum How to use checksums |
53323ebb2d0b65a5e69a728234c2dae48583aec97eda18410761686b64cb488f
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is 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}
|
