Database Paper Browser

Back to papers

TelegraphCQ: Continuous Dataflow Processing for an Uncertain World

Summary: TelegraphCQ presents a continuously-adaptive dataflow engine for managing many continuous queries over high-volume, highly-variable streams, replacing static optimization with runtime adaptation. Prototype built atop PostgreSQL with adaptive operators, routing, and load-aware scheduling. (summarized by gpt-5-mini on Feb 09 2026)

Paper ID
17
Venue
CIDR
Year
2003
Pagerank
0.00041688468
Overall Rank
143 | 99.01%
DOI
-

Incoming Non-self Citations Over Time

Authors

Incoming Citations (Sorted by Pagerank)

Showing 50 of 104 citing papers.

Rank Citing Paper Year Venue Pagerank
191 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00035714897
259 High-Performance Complex Event Processing over Streams 2006 SIGMOD 0.00030155645
317 NoScope: Optimizing Neural Network Queries over Video at Scale 2017 VLDB 0.0002798145
590 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00019552343
601 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00019372971
772 Efficient Pattern Matching over Event Streams 2008 SIGMOD 0.00016790632
908 Design Considerations for High Fan-in Systems: The HiFi Approach 2005 CIDR 0.00015405471
945 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.0001512921
1,041 Adaptive Ordering of Pipelined Stream Filters 2004 SIGMOD 0.00014470785
1,296 The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses 2010 SIGMOD 0.00012742585
1,349 Streaming Pattern Discovery in Multiple Time-Series 2005 VLDB 0.00012453634
1,362 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012380613
1,467 SPADE: The System S Declarative Stream Processing Engine 2008 SIGMOD 0.00011838188
1,557 Resource Sharing in Continuous Sliding-Window Aggregates 2004 VLDB 0.00011381807
1,595 Adaptive Cleaning for RFID Data Streams 2006 VLDB 0.0001121094
1,791 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.0001052731
1,995 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.83817e-05
2,120 Using Probabilistic Models for Data Management in Acquisitional Environments 2005 CIDR 9.5017579e-05
2,129 MacroBase: Prioritizing Attention in Fast Data 2017 SIGMOD 9.4799835e-05
2,141 Online Piece-wise Linear Approximation of Numerical Streams with Precision Guarantees* 2009 VLDB 9.4561227e-05
2,204 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2986554e-05
2,270 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.149662e-05
2,341 SASE: Complex Event Processing over Streams 2007 CIDR 9.0009661e-05
2,612 Muppet: MapReduce-Style Processing of Fast Data 2012 VLDB 8.4566845e-05
2,710 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.2580301e-05
2,768 Executing Stream Joins on the Cell Processor 2007 VLDB 8.1518597e-05
3,040 How to Fit when No One Size Fits 2013 CIDR 7.6672864e-05
3,116 Learning to Create Data-Integrating Queries 2008 VLDB 7.5404022e-05
3,240 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.3277881e-05
3,253 The Case for a Signal-Oriented Data Stream Management System 2007 CIDR 7.3175849e-05
3,491 Holistic UDAFs at Streaming Speeds 2004 SIGMOD 7.0436671e-05
3,572 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 6.9525352e-05
3,843 Approximately Detecting Duplicates for Streaming Data using Stable Bloom Filters 2006 SIGMOD 6.7071097e-05
3,863 Fast Data Stream Algorithms using Associative Memories 2007 SIGMOD 6.6838674e-05
3,887 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 6.6601639e-05
4,012 Scalable Pattern Sharing on Event Streams 2016 SIGMOD 6.5338454e-05
4,263 The Case for Precision Sharing 2004 VLDB 6.3014952e-05
4,298 Query-Based Monitoring of BPEL Business Processes 2007 SIGMOD 6.2824978e-05
4,456 Real-Time Multi-Pattern Detection over Event Streams 2019 SIGMOD 6.1644341e-05
4,593 Keyword Search on Relational Data Streams 2007 SIGMOD 6.0559961e-05
4,618 Adaptive Query Processing in the Looking Glass 2005 CIDR 6.039398e-05
4,647 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB 6.01732e-05
4,673 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.0000861e-05
4,810 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 5.9018713e-05
4,824 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 5.8902451e-05
4,890 Content-Based Routing: Different Plans for Different Data 2005 VLDB 5.8477169e-05
4,934 Static Optimization of Conjunctive Queries with Sliding Windows Over Infinite Streams 2004 SIGMOD 5.815192e-05
4,945 Lifting the Burden of History from Adaptive Query Processing 2004 VLDB 5.8115261e-05
5,004 Multiple Aggregations Over Data Streams 2005 SIGMOD 5.7603173e-05
5,075 Load Management and High Availability in the Medusa Distributed Stream Processing System 2004 SIGMOD 5.7104711e-05
Previous Page 1 / 3 Next

Outgoing Citations (Sorted by Pagerank)

Showing 21 of 21 cited papers.

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

Rank Cited Paper Year Venue Pagerank
41 NiagaraCQ: A Scalable Continuous Query System for Internet Databases 2000 SIGMOD 0.00073944756
43 Models and Issues in Data Stream Systems 2002 PODS 0.00072660894
116 Eddies: Continuously Adaptive Query Processing 2000 SIGMOD 0.00046191288
151 An Evaluation of Non-Equijoin Algorithms 1991 VLDB 0.00041010211
179 Efficient and Extensible Algorithms for Multi Query Optimization 2000 SIGMOD 0.00037637319
204 Monitoring Streams – A New Class of Data Management Applications 2002 VLDB 0.00034696955
227 Efficient Filtering of XML Documents for Selective Dissemination of Information 2000 VLDB 0.0003240219
244 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00031037999
374 Continuous Queries over Append-Only Databases 1992 SIGMOD 0.00025325855
457 Cost-based Query Scrambling for Initial Delays 1998 SIGMOD 0.00022699974
497 Filtering Algorithms and Implementation for Very Fast Publish/Subscribe Systems 2001 SIGMOD 0.00021667647
617 On Computing Correlated Aggregates Over Continual Data Streams 2001 SIGMOD 0.00019048986
626 Sequence Query Processing 1994 SIGMOD 0.00018961452
699 Query Execution Techniques for Caching Expensive Methods 1996 SIGMOD 0.0001794078
794 Broadcast Disks: Data Management for Asymmetric Communication Environments 1995 SIGMOD 0.00016565323
977 Pipelining in Multi-Query Optimization 2001 PODS 0.000148774
984 Streaming Queries over Streaming Data 2002 VLDB 0.00014840586
1,026 WSQ/DSQ: A Practical Approach for Combined Querying of Databases and the Web* 2000 SIGMOD 0.00014595291
1,531 Online Dynamic Reordering for Interactive Data Processing 1999 VLDB 0.00011467334
2,319 Optimization of Sequence Queries in Database Systems 2001 PODS 9.0421991e-05
2,491 Partial Results for Online Query Processing 2002 SIGMOD 8.6497182e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
7,329 Streaming in a Connected World: Querying and Tracking Distributed Data Streams 2007 SIGMOD 4.7559363e-05
1,362 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012380613
4,673 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.0000861e-05
1,006 Adaptive Filters for Continuous Queries over Distributed Data Streams 2003 SIGMOD 0.00014684829
9,863 Continuous Query Processing in Data Streams Using Duality of Data and Queries 2006 SIGMOD 4.2636378e-05
984 Streaming Queries over Streaming Data 2002 VLDB 0.00014840586
2,491 Partial Results for Online Query Processing 2002 SIGMOD 8.6497182e-05
12,677 Fault-tolerant, Load-balancing Queries in Telegraph 2001 SIGMOD 4.1905499e-05
244 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00031037999
590 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00019552343