Skip to main content
BeamPlayArena
OFFICIAL CURATED ARENA

Apache Beam Practice Problems

Curated Big Data & Google Cloud Dataflow practice challenges across transformations, aggregations, windowing, and distributed streaming.

Your Progress
0/30 Solved
Status#Title & Topic TagsCategoryDifficultyAction
011. Filtering Even NumbersCore TransformationsEasySolve
022. Element-wise Metric ScalingCore TransformationsEasySolve
033. String Length ExtractorCore TransformationsEasySolve
044. User Identity EnrichmentCore TransformationsEasySolve
055. High-Value Payment FilterCore TransformationsEasySolve
066. Inverted Index Key SwapperCore TransformationsEasySolve
077. Word Frequency AggregatorAggregations & GroupingEasySolve
088. Global Pipeline TotalizerAggregations & GroupingEasySolve
099. Deterministic Polarity PartitioningCore TransformationsEasySolve
1010. Text NormalizationCore TransformationsEasySolve
1111. Fraudulent Transaction ClassifierCore TransformationsMediumSolve
1212. Multi-Source User Activity JoinCore TransformationsMediumSolve
1313. Flatten Nested Record BatchesCore TransformationsMediumSolve
1414. Distributed Average Sensor ReadingAggregations & GroupingMediumSolve
1515. Top-3 Leaderboard ExtractorAggregations & GroupingMediumSolve
1616. Grouped CSV String AggregatorAggregations & GroupingMediumSolve
1717. Stream DeduplicationCore TransformationsMediumSolve
1818. ISO Date Year ExtractionCore TransformationsMediumSolve
1919. Multi-Output Tagged Branch RoutingCustom DoFn & AdvancedMediumSolve
2020. Global Broadcast Side Input ShareCustom DoFn & AdvancedMediumSolve
2121. Stateful Keyed Running CounterCustom DoFn & AdvancedHardSolve
2222. Stateful User Session HistoryCustom DoFn & AdvancedHardSolve
2323. Tumbling Fixed Event-Time WindowingWindowing & StreamingHardSolve
2424. Sliding Window Moving AverageWindowing & StreamingHardSolve
2525. User Inactivity Session WindowsWindowing & StreamingHardSolve
2626. Custom Associative Product CombinerAggregations & GroupingHardSolve
2727. JSON Payload SerializationCore TransformationsHardSolve
2828. Dead Letter Queue Error IsolationCustom DoFn & AdvancedHardSolve
2929. Keyed Min & Max AggregatorAggregations & GroupingHardSolve
3030. Watermark & Event Timestamp DoFnWindowing & StreamingHardSolve
Support