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,339 | Samza: Stateful Scalable Stream Processing at LinkedIn | 2017 | VLDB | 9.0029559e-05 |
| 4,824 | Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka | 2021 | SIGMOD | 5.8902451e-05 |
| 5,942 | Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows | 2021 | SIGMOD | 5.2591128e-05 |
| 6,430 | Providing Streaming Joins as a Service at Facebook | 2018 | VLDB | 5.0587634e-05 |
| 7,371 | Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentile | 2021 | VLDB | 4.744863e-05 |
| 9,323 | Disaggregated State Management in Apache Flink® 2.0 | 2025 | VLDB | 4.351469e-05 |
| 9,497 | Scabbard: Single-Node Fault-Tolerant Stream Processing | 2022 | VLDB | 4.3300131e-05 |
| 10,518 | Styx: Transactional Stateful Functions on Streaming Dataflows | 2025 | SIGMOD | 4.1905499e-05 |
| 11,734 | Challenges and Experiences in Building an Efficient Apache Beam Runner For IBM Streams | 2018 | VLDB | 4.1905499e-05 |
| 11,812 | State Management in Apache Flink | 2017 | VLDB | 4.1905499e-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.00028059664 |
| 822 | Twitter Heron: Stream Processing at Scale | 2015 | SIGMOD | 0.00016226851 |
| 1,434 | Fast Checkpoint Recovery Algorithms for Frequently Consistent Applications | 2011 | SIGMOD | 0.00011988283 |
Previous
Page 1 / 1
Next
Semantically Similar Papers
| Overall Rank | Paper | Year | Venue | Pagerank |
|---|---|---|---|---|
| 6,628 | A Holistic View of Stream Partitioning Costs | 2017 | VLDB | 4.9833118e-05 |
| 4,789 | Consistency in a Stream Warehouse | 2011 | CIDR | 5.9144227e-05 |
| 8,721 | Robust Real-time Query Processing with QStream | 2005 | VLDB | 4.4558332e-05 |
| 4,263 | The Case for Precision Sharing | 2004 | VLDB | 6.3014952e-05 |
| 11,734 | Challenges and Experiences in Building an Efficient Apache Beam Runner For IBM Streams | 2018 | VLDB | 4.1905499e-05 |
| 11,812 | State Management in Apache Flink | 2017 | VLDB | 4.1905499e-05 |
| 2,204 | Continuous Analytics Over Discontinuous Streams | 2010 | SIGMOD | 9.2986554e-05 |
| 1,141 | Consistent Streaming Through Time: A Vision for Event Stream Processing | 2007 | CIDR | 0.00013703749 |
| 4,925 | Shared Arrangements: practical inter-query sharing for streaming dataflows | 2020 | VLDB | 5.818597e-05 |
| 4,824 | Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka | 2021 | SIGMOD | 5.8902451e-05 |