Apache Beam pipeline & Python

USE CASE:

Implemented a pipeline to process a CSV file (data source) and print some metrics
The CSV file is located in the root directory
Implemented some PTransforms and business rules

Prerequisites to run this application:

Google Colab or Local python environment with Apache Beam direct runner

Keep in touch:

Nicholas Moises: Linkedin profile