Apache Beam, a unified model for Big Data processing
summary
Apache Beam is presented as a unified programming model for Big Data batch and streaming processing. The talk explains Beam’s history from the Dataflow model to the present, highlights features like late data arrival handling, and shows that the same pipelines can run on on-prem engines such as Apache Spark or Apache Flink or in the cloud on Google Cloud Dataflow without changing code.
AI-written summary · about
chapters (17)
- 0:00Apache Beam intro
- 1:36Big Data programming evolution
- 4:50Batch vs streaming limits
- 6:13Lambda architecture challenges
- 7:22Portability and semantics
- 10:54Dataflow unification
- 14:12Key data processing questions
- 16:18Beam windows, watermarks and triggers
- 24:46Beam model deep dive
- 31:09Beam pipelines, PCollections and Transformations
- 37:53Beam IO connectors
- 43:32Java pipeline example
- 43:56Runners role and function
- 46:23Runner compatibility
- 48:07Use cases and applications
- 48:49Why Apache Beam
- 50:11Current state and outlook
related talks
41mApache Beam: Unified Data Processing
21mApache Beam (incubating)
24mApache beam and google cloud dataflow
42mApache Beam: A Unified Model for...
47mApache Beam - what do I gain?
39mApache Beam and Google Cloud DataFlow
26mBeam and dataflow: a perfect combination of parallel processing
53mStreaming data processing pipelines with Apache Beam [in Python, naturally!]
