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