DBScholar

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.00032990214
Overall Rank
111 | 99.25%
DOI
-

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@inproceedings{chandrasekaran_cidr03,
        address = {Amsterdam, Netherlands},
        series = {{CIDR} '03},
        title = {{TelegraphCQ: Continuous Dataflow Processing for an Uncertain World}},
        booktitle = {Proceedings of the {Conference} on {Innovative} {Data} {Systems} {Research}},
        author = {Chandrasekaran, Sirish and Cooper, Owen and Deshpande, Amol and Franklin, Michael J. and Hellerstein, Joseph M. and Hong, Wei and Krishnamurthy, Sailesh and Madden, Sam and Raman, Vijayshankar and Reiss, Fred and Shah, Mehul},
        year = {2003}
}

Incoming Citations (Sorted by Pagerank)

Showing 50 of 104 citing papers.

Rank Citing Paper Year Venue Pagerank
127 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00030738755
229 High-Performance Complex Event Processing over Streams 2006 SIGMOD 0.00023927582
284 NoScope: Optimizing Neural Network Queries over Video at Scale 2017 VLDB 0.00022370521
505 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00017285498
565 Efficient Pattern Matching over Event Streams 2008 SIGMOD 0.00016445548
587 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00016106078
732 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00014536846
813 Adaptive Ordering of Pipelined Stream Filters 2004 SIGMOD 0.00013846487
1,024 The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses 2010 SIGMOD 0.0001258839
1,209 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00011657178
1,252 Streaming Pattern Discovery in Multiple Time-Series 2005 VLDB 0.00011483752
1,263 Resource Sharing in Continuous Sliding-Window Aggregates 2004 VLDB 0.00011425419
1,322 Design Considerations for High Fan-in Systems: The HiFi Approach 2005 CIDR 0.00011155403
1,331 Adaptive Cleaning for RFID Data Streams 2006 VLDB 0.00011130651
1,353 SPADE: The System S Declarative Stream Processing Engine 2008 SIGMOD 0.00011061346
1,354 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.00011057534
1,688 Online Piece-wise Linear Approximation of Numerical Streams with Precision Guarantees 2009 VLDB 0.00010003536
1,789 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.7502324e-05
1,792 MacroBase: Prioritizing Attention in Fast Data 2017 SIGMOD 9.7436856e-05
1,915 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.4884706e-05
1,945 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.4348569e-05
2,314 SASE: Complex Event Processing over Streams 2007 CIDR 8.7619735e-05
2,357 Muppet: MapReduce-Style Processing of Fast Data 2012 VLDB 8.7013171e-05
2,367 Using Probabilistic Models for Data Management in Acquisitional Environments 2005 CIDR 8.6855754e-05
2,393 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.6366772e-05
2,655 Executing Stream Joins on the Cell Processor 2007 VLDB 8.2888851e-05
3,032 Learning to Create Data-Integrating Queries 2008 VLDB 7.8323614e-05
3,044 Holistic UDAFs at Streaming Speeds 2004 SIGMOD 7.820774e-05
3,202 How to Fit when No One Size Fits 2013 CIDR 7.6409287e-05
3,242 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 7.6053312e-05
3,332 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.5129799e-05
3,352 Scalable Pattern Sharing on Event Streams 2016 SIGMOD 7.4932699e-05
3,525 The Case for a Signal-Oriented Data Stream Management System 2007 CIDR 7.3436533e-05
3,533 Approximately Detecting Duplicates for Streaming Data using Stable Bloom Filters 2006 SIGMOD 7.3366144e-05
3,776 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 7.1347542e-05
3,946 Real-Time Multi-Pattern Detection over Event Streams 2019 SIGMOD 7.0046969e-05
3,978 The Case for Precision Sharing 2004 VLDB 6.9771565e-05
3,988 Adaptive Query Processing in the Looking Glass 2005 CIDR 6.9720123e-05
4,005 Fast Data Stream Algorithms using Associative Memories 2007 SIGMOD 6.9643802e-05
4,283 Lifting the Burden of History from Adaptive Query Processing 2004 VLDB 6.7836167e-05
4,378 Keyword Search on Relational Data Streams 2007 SIGMOD 6.7356271e-05
4,383 Content-Based Routing: Different Plans for Different Data 2005 VLDB 6.7329787e-05
4,389 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.7304854e-05
4,417 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 6.7148702e-05
4,517 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB 6.6481605e-05
4,583 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.6191659e-05
4,588 Join Query Optimization Techniques for Complex Event Processing Applications 2018 VLDB 6.6167545e-05
4,596 Static Optimization of Conjunctive Queries with Sliding Windows Over Infinite Streams 2004 SIGMOD 6.6133976e-05
4,623 Multiple Aggregations Over Data Streams 2005 SIGMOD 6.6012764e-05
5,049 Cache-and-Query for Wide Area Sensor Databases 2003 SIGMOD 6.3868781e-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
25 NiagaraCQ: A Scalable Continuous Query System for Internet Databases 2000 SIGMOD 0.00054667018
26 Models and Issues in Data Stream Systems 2002 PODS 0.00052982574
53 Eddies: Continuously Adaptive Query Processing 2000 SIGMOD 0.00041071971
128 Efficient and Extensible Algorithms for Multi Query Optimization 2000 SIGMOD 0.0003072825
167 Monitoring Streams – A New Class of Data Management Applications 2002 VLDB 0.0002757283
193 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00025964286
210 An Evaluation of Non-Equijoin Algorithms 1991 VLDB 0.00024797689
236 Efficient Filtering of XML Documents for Selective Dissemination of Information 2000 VLDB 0.00023721569
368 Continuous Queries over Append-Only Databases 1992 SIGMOD 0.00019968151
419 Cost-based Query Scrambling for Initial Delays 1998 SIGMOD 0.0001879684
441 Filtering Algorithms and Implementation for Very Fast Publish/Subscribe Systems 2001 SIGMOD 0.00018407547
551 On Computing Correlated Aggregates Over Continual Data Streams 2001 SIGMOD 0.00016635191
687 Sequence Query Processing 1994 SIGMOD 0.00014948592
801 Query Execution Techniques for Caching Expensive Methods 1996 SIGMOD 0.00013909408
822 Pipelining in Multi-Query Optimization 2001 PODS 0.00013807229
832 Streaming Queries over Streaming Data 2002 VLDB 0.00013736125
1,106 WSQ/DSQ: A Practical Approach for Combined Querying of Databases and the Web* 2000 SIGMOD 0.00012151041
1,680 Online Dynamic Reordering for Interactive Data Processing 1999 VLDB 0.00010024295
1,782 Broadcast Disks: Data Management for Asymmetric Communication Environments 1995 SIGMOD 9.7735503e-05
2,280 Partial Results for Online Query Processing 2002 SIGMOD 8.8129961e-05
2,524 Optimization of Sequence Queries in Database Systems 2001 PODS 8.4681197e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 7,284 Streaming in a Connected World: Querying and Tracking Distributed Data Streams 2007 SIGMOD
2 1,209 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD
3 4,583 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR
4 722 Adaptive Filters for Continuous Queries over Distributed Data Streams 2003 SIGMOD
5 10,017 Continuous Query Processing in Data Streams Using Duality of Data and Queries 2006 SIGMOD
6 832 Streaming Queries over Streaming Data 2002 VLDB
7 2,280 Partial Results for Online Query Processing 2002 SIGMOD
8 12,861 Fault-tolerant, Load-balancing Queries in Telegraph 2001 SIGMOD
9 193 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD
10 505 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD