'No One at Google Uses MapReduce Anymore' - Cloud Dataflow
summary
Explains Google's move beyond MapReduce to newer models—Flume for pipeline definition and MillWheel for real-time dataflow—and introduces Cloud Dataflow, a public tool for specifying and running both batch and streaming pipelines at Google scale. Covers the post-MapReduce dataflow model, the underlying flow optimization algorithms, and how Cloud Dataflow automatically deploys and manages many machines for parallel processing.
AI-written summary · about
chapters (14)
- 0:00Cloud Dataflow intro
- 1:07MapReduce limitations
- 3:39MapReduce to Dataflow
- 8:36Associative reductions
- 11:49Flume Java primitives
- 20:10Execution graph optimization
- 25:08Graph pattern matching
- 31:29Optimizing execution
- 33:15Dataflow vs others
- 36:41Real-time streaming
- 38:31Q&A Java Pig
- 41:18Q&A Local execution
- 43:02Q&A Flume Java
- 44:33Q&A Deployment autoscaling
related talks
41mReal-time Data Processing with Cloud Dataflow
24mApache beam and google cloud dataflow
41mGoogle Dataflow: New open model for batch & stream processing
39mApache Beam and Google Cloud DataFlow
26mBeam and dataflow: a perfect combination of parallel processing
26mETL pipeline with GCP Dataflow
38mShall We Talk About Data Pipelines?
44mBig Data Science on Google Cloud
