DBScholar

Back to papers

The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing

Summary: Introduces the Dataflow Model for massive-scale, unbounded, out-of-order streams, treating results as perpetually evolving rather than eventually complete. Exposes principled tradeoffs among event-time correctness, latency, and cost via watermarks, triggers, and retractions. (summarized by gpt-5.6-luna on Jul 24 2026)

Paper ID
h3eb25e9eb82dd88c
Venue
VLDB
Year
2015
Pagerank
0.0002095522
Overall Rank
325 | 97.82%
DOI
10.14778/2824032.2824076
PDF
Download (CC BY-NC-ND 3.0)

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@article{akidau_vldb15,
        title = {{The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing}},
        author = {Akidau, Tyler and Bradshaw, Robert and Chambers, Craig and Chernyak, Slava and Fernández-Moctezuma, Rafael J. and Lax, Reuven and McVeety, Sam and Mills, Daniel and Perry, Frances and Schmidt, Eric and Whittle, Sam},
        journal = {PVLDB},
        series = {{VLDB} '15},
        volume = {8},
        number = {12},
        pages = {1792--1803},
        doi = {10.14778/2824032.2824076},
        url = {https://doi.org/10.14778/2824032.2824076},
        year = {2015}
}

Incoming Citations (Sorted by Pagerank)

Showing 50 of 72 citing papers.

Rank Citing Paper Year Venue Pagerank
1,123 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.00011926683
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,771 Samza: Stateful Scalable Stream Processing at LinkedIn 2017 VLDB 9.6757926e-05
2,788 Lethe: A Tunable Delete-Aware LSM Engine 2020 SIGMOD 8.0114055e-05
2,873 SnappyData: A Unified Cluster for Streaming, Transactions, and Interactive Analytics 2017 CIDR 7.9190136e-05
2,916 F1 Query: Declarative Querying at Scale 2018 VLDB 7.8581972e-05
3,034 Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems 2018 VLDB 7.7301387e-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,757 Parallel Algorithms for Constructing Range and Nearest-Neighbor Searching Data Structures 2016 PODS 7.0419501e-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,453 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.59179e-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,649 TcpRT: Instrument and Diagnostic Analysis System for Service Quality of Cloud Databases at Massive Scale in Real-time 2018 SIGMOD 6.0497711e-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,270 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8275729e-05
6,543 A Holistic View of Stream Partitioning Costs 2017 VLDB 5.7496377e-05
6,601 AStream: Ad-hoc Shared Stream Processing 2019 SIGMOD 5.737728e-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
6,801 Intermittent Query Processing 2019 VLDB 5.6776677e-05
7,322 Ananke: A Streaming Framework for Live Forward Provenance 2021 VLDB 5.5517489e-05
7,413 POLAR: Adaptive and Non-invasive Join Order Selection via Plans of Least Resistance 2024 VLDB 5.5316834e-05
7,667 CYADB: A Database that Covers Your Ask 2018 VLDB 5.4746904e-05
7,807 Erebus: Explaining the Outputs of Data Streaming Queries 2023 VLDB 5.4480616e-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,410 Spur: Mitigating Slow Instances in Large-Scale Streaming Pipelines 2020 SIGMOD 5.3360542e-05
8,686 Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing Systems 2020 SIGMOD 5.2882799e-05
8,859 VStream: A Distributed Streaming Vector Search System 2025 VLDB 5.2621314e-05
8,910 InvaliDB: Scalable Push-Based Real-Time Queries on Top of Pull-Based Databases (Extended) 2020 VLDB 5.2534908e-05
8,954 Differentially Private Stream Processing at Scale 2024 VLDB 5.2510221e-05
9,209 Dalton: Learned Partitioning for Distributed Data Streams 2023 VLDB 5.2060149e-05
9,236 Streaming Democratized: Ease Across the Latency Spectrum with Delayed View Semantics and Snowflake Dynamic Tables 2025 SIGMOD 5.2032182e-05
9,329 CrocodileDB in Action: Resource-Efficient Query Execution by Exploiting Time Slackness 2020 VLDB 5.1921674e-05
9,482 Elasticutor: Rapid Elasticity for Realtime Stateful Stream Processing 2019 SIGMOD 5.1687151e-05
9,656 Disaggregated State Management in Apache Flink 2.0 2025 VLDB 5.142891e-05
9,738 Vortex: A Stream-oriented Storage Engine For Big Data Analytics 2024 SIGMOD 5.1325223e-05
9,923 GeaFlow: A Graph Extended and Accelerated Dataflow System 2023 SIGMOD 5.1079647e-05
10,005 cedar: Optimized and Unified Machine Learning Input Data Pipelines 2025 VLDB 5.0954911e-05
10,162 Railgun: managing large streaming windows under MAD requirements 2021 VLDB 5.0682049e-05
10,577 Enjima: A Resource-Adaptive Stream Processing System 2026 SIGMOD 4.9769913e-05
10,670 Mixtera: A Data Plane for Foundation Model Training 2026 SIGMOD 4.9769913e-05
10,739 Scarf: Self-Adaptive Tuning via Multi-Objective Reinforcement Learning for Apache Flink 2026 VLDB 4.9769913e-05
Previous Page 1 / 2 Next

Outgoing Citations (Sorted by Pagerank)

Showing 13 of 13 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