Database Paper Browser

Back to papers

Flexible Time Management in Data Stream Systems

Summary: Formalizes application-defined time in DSMSs and the correctness challenges from inter-stream skew, intra-stream disorder, and variable latency. Proposes a parametrized heartbeat-generation algorithm with runtime parameter estimation to enable correct continuous-query evaluation. (summarized by gpt-5-mini on Feb 09 2026)

Paper ID
1329
Venue
PODS
Year
2004
Pagerank
0.00023368424
Overall Rank
432 | 97.00%
DOI
-

Incoming Non-self Citations Over Time

Authors

Incoming Citations (Sorted by Pagerank)

Showing 35 of 35 citing papers.

Rank Citing Paper Year Venue Pagerank
191 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00035738595
314 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00028084774
538 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020678804
944 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00015141297
1,551 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011416058
1,790 StreamRec: A Real-Time Recommender System 2011 SIGMOD 0.00010551363
1,990 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.8472819e-05
2,101 Semantics and Evaluation Techniques for Window Aggregates in Data Streams 2005 SIGMOD 9.5429492e-05
2,198 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.308495e-05
2,879 Microsoft CEP Server and Online Behavioral Targeting 2009 VLDB 7.9695819e-05
3,158 On-the-fly Progress Detection in Iterative Stream Queries 2009 VLDB 7.4648878e-05
3,237 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.3351551e-05
3,568 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 6.9619076e-05
3,815 High-Performance Dynamic Pattern Matching over Disordered Streams 2010 VLDB 6.7333316e-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
5,182 Active Complex Event Processing over Event Streams 2011 VLDB 5.6410216e-05
5,489 To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams 2021 SIGMOD 5.4782335e-05
5,939 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 5.2641681e-05
5,971 Optimal and General Out-of-Order Sliding-Window Aggregation 2019 VLDB 5.2480159e-05
6,144 Recognizing Patterns in Streams with Imprecise Timestamps 2010 VLDB 5.1889367e-05
6,721 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 4.9492015e-05
6,767 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 4.9322174e-05
7,282 Update-Pattern-Aware Modeling and Processing of Continuous Queries 2005 SIGMOD 4.776631e-05
7,852 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 4.6352012e-05
7,859 Safety Guarantee of Continuous Join Queries over Punctuated Data Streams 2006 VLDB 4.6341054e-05
8,349 Event Trend Aggregation Under Rich Event Matching Semantics 2019 SIGMOD 4.5405018e-05
8,816 DLACEP: A Deep-Learning Based Framework for Approximate Complex Event Processing 2022 SIGMOD 4.4430954e-05
8,987 Differentially Private Stream Processing at Scale* 2024 VLDB 4.4144429e-05
9,318 Disaggregated State Management in Apache Flink® 2.0 2025 VLDB 4.3556432e-05
9,551 Data Integration and Data Exchange: It’s Really About Time 2013 CIDR 4.3255102e-05
9,650 Dynamic Graph Databases with Out-of-order Updates 2024 VLDB 4.3109001e-05
10,766 Scribe: How Meta transports terabytes per second in real time 2025 VLDB 4.1945683e-05
11,468 Klink: Progress-Aware Scheduling for Streaming Data Systems 2021 SIGMOD 4.1945683e-05
12,313 Supporting a Spectrum of Out-of-Order Event Processing Technologies: From Aggressive to Conservative Methodologies 2009 SIGMOD 4.1945683e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 5 of 5 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
293 A Taxonomy of Time in Databases 1985 SIGMOD 0.00028676087
625 Sequence Query Processing 1994 SIGMOD 0.00018980669
1,136 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00013760154
1,319 Real-Time Databases 1991 VLDB 0.00012622184
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
1,003 Adaptive Filters for Continuous Queries over Distributed Data Streams 2003 SIGMOD 0.00014698435
2,198 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.308495e-05
1,141 Consistent Streaming Through Time: A Vision for Event Stream Processing 2007 CIDR 0.00013717279
7,334 Streaming in a Connected World: Querying and Tracking Distributed Data Streams 2007 SIGMOD 4.7604215e-05
4,788 Consistency in a Stream Warehouse 2011 CIDR 5.9200462e-05
43 Models and Issues in Data Stream Systems 2002 PODS 0.00072723062
3,237 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.3351551e-05
8,723 Robust Real-time Query Processing with QStream 2005 VLDB 4.4601084e-05
13,578 Scheduling Continuous Queries in Data Stream Management Systems 2008 VLDB -
8,682 Efficient Scheduling of Heterogeneous Continuous Queries 2006 VLDB 4.4687791e-05