DBScholar

Back to papers

MillWheel: Fault-Tolerant Stream Processing at Internet Scale

Summary: MillWheel is a Google-scale, low-latency stream-processing framework where users define computation graphs while the system manages persistent state, record flow, and fault tolerance. Its distinctive logical-time programming model simplifies time-based aggregation alongside scalable, resilient execution. (summarized by gpt-5.6-luna on Jul 24 2026)

Paper ID
h17732676c490721e
Venue
VLDB
Year
2013
Pagerank
0.00024379041
Overall Rank
218 | 98.54%
DOI
10.14778/2536222.2536229

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@article{akidau_vldb13,
        title = {{MillWheel: Fault-Tolerant Stream Processing at Internet Scale}},
        author = {Akidau, Tyler and Balikov, Alex and Bekiroğlu, Kaya and Chernyak, Slava and Haberman, Josh and Lax, Reuven and McVeety, Sam and Mills, Daniel and Nordstrom, Paul and Whittle, Sam},
        journal = {PVLDB},
        series = {{VLDB} '13},
        volume = {6},
        number = {11},
        pages = {1033--1044},
        doi = {10.14778/2536222.2536229},
        url = {https://doi.org/10.14778/2536222.2536229},
        year = {2013}
}

Incoming Citations (Sorted by Pagerank)

Showing 50 of 70 citing papers.

Rank Citing Paper Year Venue Pagerank
231 Storm @Twitter 2014 SIGMOD 0.00023830094
325 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.0002095522
606 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015627966
685 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014778299
1,236 Dhalion: Self-Regulating Stream Processing in Heron 2017 VLDB 0.00011400483
1,303 Realtime Data Processing at Facebook 2016 SIGMOD 0.00011101274
1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010766851
1,633 Summingbird: A Framework for Integrating Batch and Online MapReduce Computations 2014 VLDB 0.00010015001
1,771 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.6757926e-05
1,939 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.3299482e-05
2,719 Partial Results in Database Systems 2014 SIGMOD 8.0942034e-05
2,740 General Incremental Sliding-Window Aggregation 2015 VLDB 8.0682988e-05
2,873 SnappyData: A Unified Cluster for Streaming, Transactions, and Interactive Analytics 2017 CIDR 7.9190136e-05
3,034 Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems 2018 VLDB 7.7301387e-05
3,108 SABER: Window-Based Hybrid Stream Processing for Heterogeneous Architectures 2016 SIGMOD 7.6392673e-05
3,128 How to Win a Hot Dog Eating Contest: Distributed Incremental View Maintenance with Batch Updates 2016 SIGMOD 7.611678e-05
3,370 Frontier: Resilient Edge Processing for the Internet of Things 2018 VLDB 7.3660727e-05
3,383 Timon: A Timestamped Event Database for Efficient Telemetry Data Processing and Analytics 2020 SIGMOD 7.3524665e-05
3,398 Megaphone: Latency-conscious state migration for distributed streaming dataflows 2019 VLDB 7.3318754e-05
3,863 Husky: Towards a More Efficient and Expressive Distributed Computing Framework 2016 VLDB 6.961908e-05
3,923 Analyzing Efficient Stream Processing on Modern Hardware 2019 VLDB 6.919667e-05
4,110 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 6.797656e-05
4,310 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 6.6700421e-05
4,453 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.59179e-05
4,781 Tornado: A System For Real-Time Iterative Analysis Over Evolving Data 2016 SIGMOD 6.4154314e-05
4,867 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 6.3723904e-05
4,886 One SQL to Rule Them All – an Efficient and Syntactically Idiomatic Approach to Management of Streams and Tables 2019 SIGMOD 6.3680255e-05
4,919 LightSaber: Efficient Window Aggregation on Multi-core Processors 2020 SIGMOD 6.3519157e-05
5,845 Optimal and General Out-of-Order Sliding-Window Aggregation 2019 VLDB 5.9703333e-05
5,939 StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance 2023 VLDB 5.9378976e-05
6,176 Helios: Hyperscale Indexing for the Cloud & Edge 2020 VLDB 5.8585082e-05
6,228 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.8427633e-05
6,245 Pixida: Optimizing Data Parallel Jobs in Wide-Area Data Analytics 2016 VLDB 5.8353445e-05
6,270 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8275729e-05
6,444 Grizzly: Efficient Stream Processing Through Adaptive Query Compilation 2020 SIGMOD 5.7807677e-05
6,626 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 5.7288333e-05
6,793 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.6793645e-05
7,014 Incremental Sliding Window Connectivity over Streaming Graphs 2024 VLDB 5.6184803e-05
7,270 What's the Difference? Incremental Processing with Change Queries in Snowflake 2023 SIGMOD 5.5671818e-05
7,317 Model-Free Control for Distributed Stream Data Processing using Deep Reinforcement Learning 2018 VLDB 5.5523211e-05
7,322 Ananke: A Streaming Framework for Live Forward Provenance 2021 VLDB 5.5517489e-05
7,707 Enabling Efficient and General Subpopulation Analytics in Multidimensional Data Streams 2022 VLDB 5.4723863e-05
7,840 Quill: Efficient, Transferable, and Rich Analytics at Scale 2016 VLDB 5.4409637e-05
7,980 Rethinking Stateful Stream Processing with RDMA 2022 SIGMOD 5.4120499e-05
8,567 Efficient Incrementialization of Correlated Nested Aggregate Queries using Relative Partial Aggregate Indexes (RPAI) 2022 SIGMOD 5.3118554e-05
8,910 InvaliDB: Scalable Push-Based Real-Time Queries on Top of Pull-Based Databases (Extended) 2020 VLDB 5.2534908e-05
9,088 Texera: A System for Collaborative and Interactive Data Analytics Using Workflows 2024 VLDB 5.2258409e-05
9,236 Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables 2025 SIGMOD 5.2032182e-05
9,482 Elasticutor: Rapid Elasticity for Realtime Stateful Stream Processing 2019 SIGMOD 5.1687151e-05
9,641 Shrink - Prescribing Resiliency Solutions for Streaming 2017 VLDB 5.1446858e-05
Previous Page 1 / 2 Next

Outgoing Citations (Sorted by Pagerank)

Showing 10 of 10 cited papers.

Citations counted here include only citations to other VLDB/SIGMOD/CIDR/PODS papers in this database.

Previous Page 1 / 1 Next

Semantically Similar Papers