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.00041725802
Overall Rank
142 | 99.02%
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.00035738595
259 High-Performance Complex Event Processing over Streams 2006 SIGMOD 0.00030174924
316 NoScope: Optimizing Neural Network Queries over Video at Scale 2017 VLDB 0.00027988668
591 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00019569071
600 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.0001938744
776 Efficient Pattern Matching over Event Streams 2008 SIGMOD 0.00016799754
911 Design Considerations for High Fan-in Systems: The HiFi Approach 2005 CIDR 0.00015419842
944 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00015141297
1,043 Adaptive Ordering of Pipelined Stream Filters 2004 SIGMOD 0.00014476247
1,299 The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses 2010 SIGMOD 0.00012751522
1,346 Streaming Pattern Discovery in Multiple Time-Series 2005 VLDB 0.00012466288
1,357 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012392275
1,467 SPADE: The System S Declarative Stream Processing Engine 2008 SIGMOD 0.00011849864
1,554 Resource Sharing in Continuous Sliding-Window Aggregates 2004 VLDB 0.00011400581
1,594 Adaptive Cleaning for RFID Data Streams 2006 VLDB 0.00011222484
1,788 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.00010555742
1,990 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.8472819e-05
2,118 Using Probabilistic Models for Data Management in Acquisitional Environments 2005 CIDR 9.5100739e-05
2,126 MacroBase: Prioritizing Attention in Fast Data 2017 SIGMOD 9.4887794e-05
2,140 Online Piece-wise Linear Approximation of Numerical Streams with Precision Guarantees* 2009 VLDB 9.4626098e-05
2,198 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.308495e-05
2,264 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.1575142e-05
2,340 SASE: Complex Event Processing over Streams 2007 CIDR 9.004232e-05
2,605 Muppet: MapReduce-Style Processing of Fast Data 2012 VLDB 8.4646171e-05
2,706 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.2673299e-05
2,763 Executing Stream Joins on the Cell Processor 2007 VLDB 8.1579306e-05
3,034 How to Fit when No One Size Fits 2013 CIDR 7.6752083e-05
3,110 Learning to Create Data-Integrating Queries 2008 VLDB 7.5475982e-05
3,237 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.3351551e-05
3,249 The Case for a Signal-Oriented Data Stream Management System 2007 CIDR 7.3249002e-05
3,486 Holistic UDAFs at Streaming Speeds 2004 SIGMOD 7.0502199e-05
3,568 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 6.9619076e-05
3,838 Approximately Detecting Duplicates for Streaming Data using Stable Bloom Filters 2006 SIGMOD 6.7134945e-05
3,860 Fast Data Stream Algorithms using Associative Memories 2007 SIGMOD 6.6902516e-05
3,886 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 6.6661649e-05
4,007 Scalable Pattern Sharing on Event Streams 2016 SIGMOD 6.5397067e-05
4,267 The Case for Precision Sharing 2004 VLDB 6.3084955e-05
4,305 Query-Based Monitoring of BPEL Business Processes 2007 SIGMOD 6.2885419e-05
4,457 Real-Time Multi-Pattern Detection over Event Streams 2019 SIGMOD 6.1702339e-05
4,592 Keyword Search on Relational Data Streams 2007 SIGMOD 6.0613645e-05
4,617 Adaptive Query Processing in the Looking Glass 2005 CIDR 6.0446738e-05
4,649 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB 6.0236001e-05
4,673 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.0058653e-05
4,810 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 5.9073964e-05
4,822 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 5.8959131e-05
4,883 Content-Based Routing: Different Plans for Different Data 2005 VLDB 5.8545658e-05
4,930 Static Optimization of Conjunctive Queries with Sliding Windows Over Infinite Streams 2004 SIGMOD 5.8213082e-05
4,943 Lifting the Burden of History from Adaptive Query Processing 2004 VLDB 5.8170713e-05
5,001 Multiple Aggregations Over Data Streams 2005 SIGMOD 5.7678084e-05
5,076 Load Management and High Availability in the Medusa Distributed Stream Processing System 2004 SIGMOD 5.7166494e-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.00073964959
43 Models and Issues in Data Stream Systems 2002 PODS 0.00072723062
115 Eddies: Continuously Adaptive Query Processing 2000 SIGMOD 0.00046221215
152 An Evaluation of Non-Equijoin Algorithms 1991 VLDB 0.00040963225
179 Efficient and Extensible Algorithms for Multi Query Optimization 2000 SIGMOD 0.00037672155
205 Monitoring Streams – A New Class of Data Management Applications 2002 VLDB 0.00034731577
226 Efficient Filtering of XML Documents for Selective Dissemination of Information 2000 VLDB 0.00032431532
244 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00031066222
373 Continuous Queries over Append-Only Databases 1992 SIGMOD 0.00025341527
456 Cost-based Query Scrambling for Initial Delays 1998 SIGMOD 0.00022717134
500 Filtering Algorithms and Implementation for Very Fast Publish/Subscribe Systems 2001 SIGMOD 0.00021637423
619 On Computing Correlated Aggregates Over Continual Data Streams 2001 SIGMOD 0.00019066583
625 Sequence Query Processing 1994 SIGMOD 0.00018980669
703 Query Execution Techniques for Caching Expensive Methods 1996 SIGMOD 0.00017916705
798 Broadcast Disks: Data Management for Asymmetric Communication Environments 1995 SIGMOD 0.00016579273
977 Pipelining in Multi-Query Optimization 2001 PODS 0.0001488881
985 Streaming Queries over Streaming Data 2002 VLDB 0.00014852471
1,025 WSQ/DSQ: A Practical Approach for Combined Querying of Databases and the Web* 2000 SIGMOD 0.00014603741
1,531 Online Dynamic Reordering for Interactive Data Processing 1999 VLDB 0.00011482597
2,314 Optimization of Sequence Queries in Database Systems 2001 PODS 9.0479606e-05
2,492 Partial Results for Online Query Processing 2002 SIGMOD 8.6526489e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
7,334 Streaming in a Connected World: Querying and Tracking Distributed Data Streams 2007 SIGMOD 4.7604215e-05
1,357 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00012392275
4,673 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.0058653e-05
1,003 Adaptive Filters for Continuous Queries over Distributed Data Streams 2003 SIGMOD 0.00014698435
9,864 Continuous Query Processing in Data Streams Using Duality of Data and Queries 2006 SIGMOD 4.2675822e-05
985 Streaming Queries over Streaming Data 2002 VLDB 0.00014852471
2,492 Partial Results for Online Query Processing 2002 SIGMOD 8.6526489e-05
12,668 Fault-tolerant, Load-balancing Queries in Telegraph 2001 SIGMOD 4.1945683e-05
244 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00031066222
591 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00019569071