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
5,097 Join Query Optimization Techniques for Complex Event Processing Applications 2018 VLDB 5.7011496e-05
5,117 Sampling Algorithms in a Stream Operator 2005 SIGMOD 5.6825418e-05
5,342 Cache-and-Query for Wide Area Sensor Databases 2003 SIGMOD 5.5581569e-05
5,489 To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams 2021 SIGMOD 5.4782335e-05
5,547 Network-Aware Query Processing for Stream-based Applications 2004 VLDB 5.4457955e-05
5,657 BriskStream: Scaling Data Stream Processing on Shared-Memory Multicore Architectures 2019 SIGMOD 5.3864606e-05
5,713 Remembrance of Streams Past: Overload-Sensitive Management of Archived Streams 2004 VLDB 5.3581653e-05
5,727 Enabling Incremental Query Re-Optimization 2016 SIGMOD 5.3510544e-05
6,048 Load Shedding in Stream Databases: A Control-Based Approach 2006 VLDB 5.2365988e-05
6,176 MonetDB/DataCell: Online Analytics in a Streaming Column-Store 2012 VLDB 5.169318e-05
6,271 DARLING: Data-Aware Load Shedding in Complex Event Processing Systems 2022 VLDB 5.1335397e-05
6,478 An Integration Framework for Sensor Networks and Data Stream Management Systems 2004 VLDB 5.0487293e-05
6,487 Inter-Operator Feedback in Data Stream Management Systems via Punctuation 2009 CIDR 5.0435729e-05
6,535 Effective Variation Management for Pseudo Periodical Streams 2007 SIGMOD 5.0243433e-05
6,629 A Holistic View of Stream Partitioning Costs 2017 VLDB 4.9880986e-05
6,648 Grizzly: Efficient Stream Processing Through Adaptive Query Compilation 2020 SIGMOD 4.9771723e-05
6,654 Moirae: History-Enhanced Monitoring 2007 CIDR 4.9733876e-05
7,027 Query-Aware Partitioning for Monitoring Massive Network Data Streams 2008 SIGMOD 4.8569938e-05
7,206 HiFi: A Unified Architecture for High Fan-in Systems (System Demonstration) 2004 VLDB 4.8008153e-05
7,213 SmartCIS: Integrating Digital and Physical Environments 2009 SIGMOD 4.7989853e-05
7,242 Challenges and Experience in Prototyping a Multi-Modal Stream Analytic and Monitoring Application on System S 2007 VLDB 4.7919756e-05
7,318 Efficient Adaptive Detection of Complex Event Patterns 2018 VLDB 4.7638874e-05
7,407 Intermittent Query Processing 2019 VLDB 4.7373205e-05
7,670 Extending XQuery with Window Functions 2007 VLDB 4.682982e-05
7,701 Resource-efficient Shared Query Execution via Exploiting Time Slackness 2021 SIGMOD 4.6741329e-05
7,736 From a Stream of Relational Queries to Distributed Stream Processing 2010 VLDB 4.664248e-05
7,806 Adaptive Execution of Variable-Accuracy Functions 2006 VLDB 4.6459438e-05
7,860 CAPE: Continuous Query Engine with Heterogeneous-Grained Adaptivity 2004 VLDB 4.6341054e-05
7,878 DBToaster: Agile Views in a Dynamic Data Management System 2011 CIDR 4.6295401e-05
7,893 Changing Flights in Mid-air: A Model for Safely Modifying Continuous Queries 2011 SIGMOD 4.6240987e-05
8,047 Thrifty Query Execution via Incrementability 2020 SIGMOD 4.5983505e-05
8,306 Online Windowed Subsequence Matching over Probabilistic Sequences 2012 SIGMOD 4.5435639e-05
8,530 HYPERSONIC: A Hybrid Parallelization Approach for Scalable Complex Event Processing 2022 SIGMOD 4.4937074e-05
8,560 Monitoring Business Processes with Queries 2007 VLDB 4.4937074e-05
8,561 StreamGlobe: Processing and Sharing Data Streams in Grid-Based P2P Infrastructures 2005 VLDB 4.4937074e-05
8,869 Sharing-Aware Horizontal Partitioning for Exploiting Correlations During Query Processing 2010 VLDB 4.4320338e-05
9,063 Data Stream Management for Historical XML Data 2004 SIGMOD 4.4039656e-05
9,187 POLAR: Adaptive and Non-invasive Join Order Selection via Plans of Least Resistance 2024 VLDB 4.3780059e-05
9,313 Providing Resiliency to Load Variations in Distributed Stream Processing 2006 VLDB 4.3565355e-05
9,504 Supporting Scalable Analytics with Latency Constraints 2015 VLDB 4.3341665e-05
9,803 Railgun: managing large streaming windows under MAD requirements 2021 VLDB 4.2807806e-05
9,864 Continuous Query Processing in Data Streams Using Duality of Data and Queries 2006 SIGMOD 4.2675822e-05
9,922 Request Window: an Approach to Improve Throughput of RDBMS-based Data Integration System by Utilizing Data Sharing Across Concurrent Distributed Queries 2007 VLDB 4.2549509e-05
10,280 Meerkat: Scalable, Network-Aware Failure Recovery for the Internet of Things 2026 VLDB 4.1945683e-05
11,435 Synchronization Schemas 2021 PODS 4.1945683e-05
11,673 Online Template Induction for Machine-Generated Emails 2019 VLDB 4.1945683e-05
11,756 Prioritizing Attention in Fast Data: Principles and Promise 2017 CIDR 4.1945683e-05
12,047 Execution and Optimization of Continuous Queries with Cyclops 2013 SIGMOD 4.1945683e-05
12,254 iFlow: An Approach for Fast and Reliable Internet-Scale Stream Processing Utilizing Detouring and Replication 2010 VLDB 4.1945683e-05
12,385 LeeWave: Level-Wise Distribution of Wavelet Coefficients for Processing kNN Queries over Distributed Streams 2008 VLDB 4.1945683e-05
Previous Page 2 / 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