ramijaber4/e-commerceetl

This is a PySpark Customer 360 ETL application. Its main workflow reads CSV datasets, enforces schemas, cleans entity records, joins transactions with customer, country, and product data, adds business metrics, runs regional and commercial aggregations, and writes Parquet output. Reviews are extracted and cleaned but are not used in the joined output in the sampled entry point. The tree omits transactions.csv despite README references; the graph therefore treats data/ as the documented input source without asserting that file is present. Wiring reflects the sampled main.py and module calls.