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.00032459277
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.00030427614
241 High-Performance Complex Event Processing over Streams 2006 SIGMOD 0.00023419748
271 NoScope: Optimizing Neural Network Queries over Video at Scale 2017 VLDB 0.00022560564
510 TelegraphCQ: Continuous Dataflow Processing 2003 SIGMOD 0.00017065714
580 Efficient Pattern Matching over Event Streams 2008 SIGMOD 0.00016085679
594 Linear Road: A Stream Data Management Benchmark 2004 VLDB 0.00015823573
755 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00014232741
827 Adaptive Ordering of Pipelined Stream Filters 2004 SIGMOD 0.00013632674
1,040 The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses 2010 SIGMOD 0.00012364063
1,228 Highly Available, Fault-Tolerant, Parallel Dataflows 2004 SIGMOD 0.00011425028
1,278 Streaming Pattern Discovery in Multiple Time-Series 2005 VLDB 0.00011231952
1,286 Resource Sharing in Continuous Sliding-Window Aggregates 2004 VLDB 0.0001119284
1,358 Design Considerations for High Fan-in Systems: The HiFi Approach 2005 CIDR 0.00010922626
1,360 Adaptive Cleaning for RFID Data Streams 2006 VLDB 0.00010918075
1,383 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.00010847646
1,386 SPADE: The System S Declarative Stream Processing Engine 2008 SIGMOD 0.00010843396
1,713 Online Piece-wise Linear Approximation of Numerical Streams with Precision Guarantees 2009 VLDB 9.8143771e-05
1,828 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.5516021e-05
1,833 MacroBase: Prioritizing Attention in Fast Data 2017 SIGMOD 9.5405247e-05
1,938 S-Store: Streaming Meets Transaction Processing 2015 VLDB 9.3342542e-05
1,985 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2521678e-05
2,363 SASE: Complex Event Processing over Streams 2007 CIDR 8.5673723e-05
2,397 Muppet: MapReduce-Style Processing of Fast Data 2012 VLDB 8.5227959e-05
2,415 Using Probabilistic Models for Data Management in Acquisitional Environments 2005 CIDR 8.4985276e-05
2,444 Design, Implementation, and Evaluation of the Linear Road Benchmark on the Stream Processing Core 2006 SIGMOD 8.4583264e-05
2,696 Executing Stream Joins on the Cell Processor 2007 VLDB 8.1205649e-05
3,088 Learning to Create Data-Integrating Queries 2008 VLDB 7.6596008e-05
3,094 Holistic UDAFs at Streaming Speeds 2004 SIGMOD 7.6533343e-05
3,251 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 7.4932341e-05
3,258 How to Fit when No One Size Fits 2013 CIDR 7.4873069e-05
3,324 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.4285048e-05
3,410 Scalable Pattern Sharing on Event Streams 2016 SIGMOD 7.3258817e-05
3,547 Approximately Detecting Duplicates for Streaming Data using Stable Bloom Filters 2006 SIGMOD 7.2121974e-05
3,594 The Case for a Signal-Oriented Data Stream Management System 2007 CIDR 7.1824376e-05
3,790 Fault-tolerant Stream Processing using a Distributed, Replicated File System 2008 VLDB 7.0190297e-05
4,023 Real-Time Multi-Pattern Detection over Event Streams 2019 SIGMOD 6.8476587e-05
4,045 Adaptive Query Processing in the Looking Glass 2005 CIDR 6.8328968e-05
4,056 The Case for Precision Sharing 2004 VLDB 6.8261065e-05
4,097 Fast Data Stream Algorithms using Associative Memories 2007 SIGMOD 6.8092798e-05
4,106 Content-Based Routing: Different Plans for Different Data 2005 VLDB 6.8032891e-05
4,366 Lifting the Burden of History from Adaptive Query Processing 2004 VLDB 6.6333069e-05
4,447 Keyword Search on Relational Data Streams 2007 SIGMOD 6.5968014e-05
4,450 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.594912e-05
4,515 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 6.5648144e-05
4,590 Window-Aware Load Shedding for Aggregation Queries over Data Streams 2006 VLDB 6.5139479e-05
4,621 Join Query Optimization Techniques for Complex Event Processing Applications 2018 VLDB 6.4987856e-05
4,684 Continuous Analytics: Rethinking Query Processing in a Network-Effect World 2009 CIDR 6.4714032e-05
4,693 Static Optimization of Conjunctive Queries with Sliding Windows Over Infinite Streams 2004 SIGMOD 6.4662079e-05
4,720 Multiple Aggregations Over Data Streams 2005 SIGMOD 6.4544772e-05
5,173 Cache-and-Query for Wide Area Sensor Databases 2003 SIGMOD 6.243639e-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.00053930011
26 Models and Issues in Data Stream Systems 2002 PODS 0.00052121228
53 Eddies: Continuously Adaptive Query Processing 2000 SIGMOD 0.00040860054
129 Efficient and Extensible Algorithms for Multi Query Optimization 2000 SIGMOD 0.0003040756
171 Monitoring Streams – A New Class of Data Management Applications 2002 VLDB 0.00027011593
200 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.000254553
220 An Evaluation of Non-Equijoin Algorithms 1991 VLDB 0.00024344086
247 Efficient Filtering of XML Documents for Selective Dissemination of Information 2000 VLDB 0.00023199427
369 Continuous Queries over Append-Only Databases 1992 SIGMOD 0.00019854467
424 Cost-based Query Scrambling for Initial Delays 1998 SIGMOD 0.0001848836
451 Filtering Algorithms and Implementation for Very Fast Publish/Subscribe Systems 2001 SIGMOD 0.00018025073
566 On Computing Correlated Aggregates Over Continual Data Streams 2001 SIGMOD 0.00016295476
706 Sequence Query Processing 1994 SIGMOD 0.00014643264
821 Query Execution Techniques for Caching Expensive Methods 1996 SIGMOD 0.00013660347
831 Pipelining in Multi-Query Optimization 2001 PODS 0.00013589597
852 Streaming Queries over Streaming Data 2002 VLDB 0.00013451343
1,130 WSQ/DSQ: A Practical Approach for Combined Querying of Databases and the Web* 2000 SIGMOD 0.00011902078
1,703 Online Dynamic Reordering for Interactive Data Processing 1999 VLDB 9.8315219e-05
1,817 Broadcast Disks: Data Management for Asymmetric Communication Environments 1995 SIGMOD 9.5749088e-05
2,324 Partial Results for Online Query Processing 2002 SIGMOD 8.6310477e-05
2,569 Optimization of Sequence Queries in Database Systems 2001 PODS 8.2869645e-05
Previous Page 1 / 1 Next

Semantically Similar Papers