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
h1e5cf29c13d07334
Venue
CIDR
Year
2003
Pagerank
0.00032445088
Overall Rank
112 | 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 105 citing papers.

Rank Citing Paper Year Venue Pagerank
127 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00030414379
241 High-Performance Complex Event Processing over Streams 2006 SIGMOD 0.00023408695
271 NoScope: Optimizing Neural Network Queries over Video at Scale 2017 VLDB 0.0002256866
511 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00017058115
580 Efficient Pattern Matching over Event Streams 2008 SIGMOD 0.0001607809
594 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00015816384
755 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00014226048
827 Adaptive Ordering of Pipelined Stream Filters 2004 SIGMOD 0.00013629035
1,040 The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses 2010 SIGMOD 0.00012358804
1,230 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00011419665
1,279 Streaming Pattern Discovery in Multiple Time-Series 2005 VLDB 0.00011226666
1,286 Resource Sharing in Continuous Sliding-Window Aggregates 2004 VLDB 0.00011188038
1,358 Design Considerations for High Fan-in Systems: The HiFi Approach 2005 CIDR 0.00010917457
1,361 Adaptive Cleaning for RFID Data Streams 2006 VLDB 0.00010912941
1,383 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.00010842596
1,386 SPADE: The System S Declarative Stream Processing Engine 2008 SIGMOD 0.00010838275
1,714 Online Piece-wise Linear Approximation of Numerical Streams with Precision Guarantees 2009 VLDB 9.8119635e-05
1,829 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.5470848e-05
1,833 MacroBase: Prioritizing Attention in Fast Data 2017 SIGMOD 9.5376219e-05
1,939 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.3299482e-05
1,987 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2478037e-05
2,364 SASE: Complex Event Processing over Streams 2007 CIDR 8.5633583e-05
2,398 Muppet: MapReduce-Style Processing of Fast Data 2012 VLDB 8.5187919e-05
2,416 Using Probabilistic Models for Data Management in Acquisitional Environments 2005 CIDR 8.4946354e-05
2,446 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.4544371e-05
2,694 Executing Stream Joins on the Cell Processor 2007 VLDB 8.1197353e-05
3,090 Learning to Create Data-Integrating Queries 2008 VLDB 7.6561778e-05
3,096 Holistic UDAFs at Streaming Speeds 2004 SIGMOD 7.6497893e-05
3,252 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 7.4897106e-05
3,258 How to Fit when No One Size Fits 2013 CIDR 7.4839611e-05
3,326 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.4250065e-05
3,410 Scalable Pattern Sharing on Event Streams 2016 SIGMOD 7.322416e-05
3,547 Approximately Detecting Duplicates for Streaming Data using Stable Bloom Filters 2006 SIGMOD 7.2088273e-05
3,595 The Case for a Signal-Oriented Data Stream Management System 2007 CIDR 7.1790428e-05
3,792 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 7.0157179e-05
4,024 Real-Time Multi-Pattern Detection over Event Streams 2019 SIGMOD 6.8444194e-05
4,046 Adaptive Query Processing in the Looking Glass 2005 CIDR 6.8297725e-05
4,057 The Case for Precision Sharing 2004 VLDB 6.8230987e-05
4,099 Fast Data Stream Algorithms using Associative Memories 2007 SIGMOD 6.8061151e-05
4,108 Content-Based Routing: Different Plans for Different Data 2005 VLDB 6.8000756e-05
4,369 Lifting the Burden of History from Adaptive Query Processing 2004 VLDB 6.6302169e-05
4,449 Keyword Search on Relational Data Streams 2007 SIGMOD 6.5936949e-05
4,453 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.59179e-05
4,517 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 6.5617068e-05
4,592 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB 6.5109054e-05
4,623 Join Query Optimization Techniques for Complex Event Processing Applications 2018 VLDB 6.4957114e-05
4,688 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.4683444e-05
4,695 Static Optimization of Conjunctive Queries with Sliding Windows Over Infinite Streams 2004 SIGMOD 6.4632424e-05
4,722 Multiple Aggregations Over Data Streams 2005 SIGMOD 6.4514279e-05
5,174 Cache-and-Query for Wide Area Sensor Databases 2003 SIGMOD 6.2406834e-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.00053906051
26 Models and Issues in Data Stream Systems 2002 PODS 0.00052097907
53 Eddies: Continuously Adaptive Query Processing 2000 SIGMOD 0.000408505
129 Efficient and Extensible Algorithms for Multi Query Optimization 2000 SIGMOD 0.00030395767
171 Monitoring Streams – A New Class of Data Management Applications 2002 VLDB 0.00026999348
200 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00025444144
220 An Evaluation of Non-Equijoin Algorithms 1991 VLDB 0.00024333068
247 Efficient Filtering of XML Documents for Selective Dissemination of Information 2000 VLDB 0.00023188523
369 Continuous Queries over Append-Only Databases 1992 SIGMOD 0.0001984577
423 Cost-based Query Scrambling for Initial Delays 1998 SIGMOD 0.00018487497
451 Filtering Algorithms and Implementation for Very Fast Publish/Subscribe Systems 2001 SIGMOD 0.00018017347
566 On Computing Correlated Aggregates Over Continual Data Streams 2001 SIGMOD 0.00016288241
706 Sequence Query Processing 1994 SIGMOD 0.0001463663
821 Query Execution Techniques for Caching Expensive Methods 1996 SIGMOD 0.00013655214
831 Pipelining in Multi-Query Optimization 2001 PODS 0.00013583882
852 Streaming Queries over Streaming Data 2002 VLDB 0.00013450014
1,131 WSQ/DSQ: A Practical Approach for Combined Querying of Databases and the Web* 2000 SIGMOD 0.00011896556
1,703 Online Dynamic Reordering for Interactive Data Processing 1999 VLDB 9.8269486e-05
1,817 Broadcast Disks: Data Management for Asymmetric Communication Environments 1995 SIGMOD 9.5704315e-05
2,327 Partial Results for Online Query Processing 2002 SIGMOD 8.6271354e-05
2,569 Optimization of Sequence Queries in Database Systems 2001 PODS 8.2832668e-05
Previous Page 1 / 1 Next

Semantically Similar Papers