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.00024390324
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.00023841089
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.00020964941
606 Twitter Heron: Stream Processing at Scale 2015 SIGMOD 0.00015635133
685 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014782777
1,233 Dhalion: Self-Regulating Stream Processing in Heron 2017 VLDB 0.00011405873
1,303 Realtime Data Processing at Facebook 2016 SIGMOD 0.0001110427
1,402 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010771949
1,633 Summingbird: A Framework for Integrating Batch and Online MapReduce Computations 2014 VLDB 0.00010019617
1,771 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.6803752e-05
1,938 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.3342542e-05
2,717 Partial Results in Database Systems 2014 SIGMOD 8.0980367e-05
2,739 General Incremental Sliding-Window Aggregation 2015 VLDB 8.0721161e-05
2,873 SnappyData: A Unified Cluster for Streaming, Transactions, and Interactive Analytics 2017 CIDR 7.9225385e-05
3,033 Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems 2018 VLDB 7.7337998e-05
3,106 SABER: Window-Based Hybrid Stream Processing for Heterogeneous Architectures 2016 SIGMOD 7.6428848e-05
3,128 How to Win a Hot Dog Eating Contest: Distributed Incremental View Maintenance with Batch Updates 2016 SIGMOD 7.6151967e-05
3,370 Frontier: Resilient Edge Processing for the Internet of Things 2018 VLDB 7.3695613e-05
3,382 Timon: A Timestamped Event Database for Efficient Telemetry Data Processing and Analytics 2020 SIGMOD 7.3559487e-05
3,398 Megaphone: Latency-conscious state migration for distributed streaming dataflows 2019 VLDB 7.3353479e-05
3,862 Husky: Towards a More Efficient and Expressive Distributed Computing Framework 2016 VLDB 6.9652009e-05
3,922 Analyzing Efficient Stream Processing on Modern Hardware 2019 VLDB 6.9229432e-05
4,109 Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines 2020 SIGMOD 6.8008755e-05
4,309 Consistent Regions: Guaranteed Tuple Processing in IBM Streams 2016 VLDB 6.6732011e-05
4,450 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.594912e-05
4,777 Tornado: A System For Real-Time Iterative Analysis Over Evolving Data 2016 SIGMOD 6.4184698e-05
4,866 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 6.3754084e-05
4,884 One SQL to Rule Them All – an Efficient and Syntactically Idiomatic Approach to Management of Streams and Tables 2019 SIGMOD 6.3710319e-05
4,918 LightSaber: Efficient Window Aggregation on Multi-core Processors 2020 SIGMOD 6.3548575e-05
5,843 Optimal and General Out-of-Order Sliding-Window Aggregation 2019 VLDB 5.9731599e-05
5,939 StreamOps: Cloud-Native Runtime Management for Streaming Services in ByteDance 2023 VLDB 5.9407099e-05
6,174 Helios: Hyperscale Indexing for the Cloud & Edge 2020 VLDB 5.8612829e-05
6,225 Providing Streaming Joins as a Service at Facebook 2018 VLDB 5.8455305e-05
6,242 Pixida: Optimizing Data Parallel Jobs in Wide-Area Data Analytics 2016 VLDB 5.8381082e-05
6,266 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8303329e-05
6,441 Grizzly: Efficient Stream Processing Through Adaptive Query Compilation 2020 SIGMOD 5.7834762e-05
6,620 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 5.7315465e-05
6,787 Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile 2021 VLDB 5.6820544e-05
7,013 Incremental Sliding Window Connectivity over Streaming Graphs 2024 VLDB 5.6211413e-05
7,267 What's the Difference? Incremental Processing with Change Queries in Snowflake 2023 SIGMOD 5.5698185e-05
7,315 Model-Free Control for Distributed Stream Data Processing using Deep Reinforcement Learning 2018 VLDB 5.554799e-05
7,319 Ananke: A Streaming Framework for Live Forward Provenance 2021 VLDB 5.5543783e-05
7,701 Enabling Efficient and General Subpopulation Analytics in Multidimensional Data Streams 2022 VLDB 5.474978e-05
7,836 Quill: Efficient, Transferable, and Rich Analytics at Scale 2016 VLDB 5.4435399e-05
7,976 Rethinking Stateful Stream Processing with RDMA 2022 SIGMOD 5.4146123e-05
8,560 Efficient Incrementialization of Correlated Nested Aggregate Queries using Relative Partial Aggregate Indexes (RPAI) 2022 SIGMOD 5.3142933e-05
8,902 InvaliDB: Scalable Push-Based Real-Time Queries on Top of Pull-Based Databases (Extended) 2020 VLDB 5.2559789e-05
9,078 Texera: A System for Collaborative and Interactive Data Analytics Using Workflows 2024 VLDB 5.2283159e-05
9,226 Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables 2025 SIGMOD 5.2056825e-05
9,471 Elasticutor: Rapid Elasticity for Realtime Stateful Stream Processing 2019 SIGMOD 5.1711628e-05
9,633 Shrink - Prescribing Resiliency Solutions for Streaming 2017 VLDB 5.1471224e-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