apache-beamEasy Playground

Unified batch and streaming data processing

Getting started with apache-beamRun locally
Install
pip install apache-beam
Python CodeRun locally
Expected Output
# Expected output shown below
# (Run locally with: apache_beam)

apache-beam is a third-party package. Unified batch and streaming data processing. Install with: pip install apache-beam

Challenge

Try modifying the code above to explore different behaviors. Can you extend the example to handle a new use case?