Consistent Regions: Guaranteed Tuple Processing in IBM Streams
Summary: Defines consistent regions in IBM Streams via source-code annotations to enclose subgraphs with guaranteed tuple processing. A runtime uses a Chandy-Lamport-style checkpoint with data replay to align region state and input, enabling end-to-end guarantees. (summarized by gpt-5-nano on Feb 09 2026)
Incoming Non-self Citations Over Time
Authors
- 1. Gabriela Jacques-Silva
- 2. Fang Zheng
- 3. Daniel Debrunner
- 4. Kun-Lung Wu
- 5. Victor Dogaru
- 6. Eric Johnson
- 7. Michael Spicer
- 8. Ahmet Erdem Sariyuce
Incoming Citations (Sorted by Pagerank)
Showing 10 of 10 citing papers.
| Rank | Citing Paper | Year | Venue | Pagerank |
|---|---|---|---|---|
| 2,338 | Samza: Stateful Scalable Stream Processing at LinkedIn | 2017 | VLDB | 9.00711e-05 |
| 4,822 | Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka | 2021 | SIGMOD | 5.8959131e-05 |
| 5,939 | Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows | 2021 | SIGMOD | 5.2641681e-05 |
| 6,436 | Providing Streaming Joins as a Service at Facebook | 2018 | VLDB | 5.0636254e-05 |
| 7,373 | Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile | 2021 | VLDB | 4.7494183e-05 |
| 9,318 | Disaggregated State Management in Apache Flink® 2.0 | 2025 | VLDB | 4.3556432e-05 |
| 9,496 | Scabbard: Single-Node Fault-Tolerant Stream Processing | 2022 | VLDB | 4.3341665e-05 |
| 10,509 | Styx: Transactional Stateful Functions on Streaming Dataflows | 2025 | SIGMOD | 4.1945683e-05 |
| 11,728 | Challenges and Experiences in Building an Efficient Apache Beam Runner For IBM Streams | 2018 | VLDB | 4.1945683e-05 |
| 11,804 | State Management in Apache Flink | 2017 | VLDB | 4.1945683e-05 |
Previous
Page 1 / 1
Next
Outgoing Citations (Sorted by Pagerank)
Showing 3 of 3 cited papers.
Citations counted here include only citations to other VLDB/SIGMOD/CIDR/PODS papers in this database.
| Rank | Cited Paper | Year | Venue | Pagerank |
|---|---|---|---|---|
| 314 | MillWheel: Fault-Tolerant Stream Processing at Internet Scale | 2013 | VLDB | 0.00028084774 |
| 824 | Twitter Heron: Stream Processing at Scale | 2015 | SIGMOD | 0.0001623129 |
| 1,436 | Fast Checkpoint Recovery Algorithms for Frequently Consistent Applications | 2011 | SIGMOD | 0.00011987961 |
Previous
Page 1 / 1
Next
Semantically Similar Papers
| Overall Rank | Paper | Year | Venue | Pagerank |
|---|---|---|---|---|
| 6,629 | A Holistic View of Stream Partitioning Costs | 2017 | VLDB | 4.9880986e-05 |
| 4,788 | Consistency in a Stream Warehouse | 2011 | CIDR | 5.9200462e-05 |
| 8,723 | Robust Real-time Query Processing with QStream | 2005 | VLDB | 4.4601084e-05 |
| 4,267 | The Case for Precision Sharing | 2004 | VLDB | 6.3084955e-05 |
| 11,728 | Challenges and Experiences in Building an Efficient Apache Beam Runner For IBM Streams | 2018 | VLDB | 4.1945683e-05 |
| 11,804 | State Management in Apache Flink | 2017 | VLDB | 4.1945683e-05 |
| 2,198 | Continuous Analytics Over Discontinuous Streams | 2010 | SIGMOD | 9.308495e-05 |
| 1,141 | Consistent Streaming Through Time: A Vision for Event Stream Processing | 2007 | CIDR | 0.00013717279 |
| 4,920 | Shared Arrangements: practical inter-query sharing for streaming dataflows | 2020 | VLDB | 5.8241888e-05 |
| 4,822 | Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka | 2021 | SIGMOD | 5.8959131e-05 |