Templates

1. Hello Beam (Map & Filter)Fundamentals

Loads numbers, filters out odd values, and squares the remaining evens.

2. Word Count AggregatorCore Transforms

Splits raw sentences into individual words, counts occurrences, and prints counts.

3. Stateful Element CounterAdvanced State

Key-value ValueState counter that keeps running tallies of elements parsed per key.

4. Streaming Fixed WindowingWindowing & Streaming

Groups timestamped mock sensor entries into 5-second fixed windows.

5. Fan-Out & Flatten MergePipeline Architecture

Branches a single collection into parallel calculations and merges outputs using Flatten.

6. Side Input LookupPatterns

Enriches records by broadcasting a dictionary payload as a side input.

7. Dead Letter Queue PatternError Handling

Routes corrupted or malformed payloads to a secondary dead-letter output branch.

Fundamentals

Wasm SandboxFundamentals

1. Hello Beam (Map & Filter)

Loads numbers, filters out odd values, and squares the remaining evens.

Python Code Editor

14px

Execution Engine:Apache Beam 2.x (Python 3.11)

Terminal Output Console

Ready to run pipeline.

Press "Run Pipeline" to execute.

Status: IDLEUTF-8 Console

Interactive Playground Quick-Start Guide

1. Choose or Write Code

Select one of the templates, or write custom Python pipelines using authentic apache_beam syntax (PCollections, ParDo, CombinePerKey, Windowing, DLQ, etc.).

2. Serverless Execution

Code executes securely in an isolated, pre-warmed sandbox running official Apache Beam 2.x and Python 3.11.

3. Read Real Pipeline Output

Check the console stream. Outputs printed via standard beam.Map(print) or logging appear directly in the output terminal.