GitHub repository: Javier009/dataproc-pyspark-bigquery-transactions-pipeline
Description: Pipeline that genrates mock data into GCS and processes it with pyspark using dataproc to perform SCD2 opearations