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.00023336894
Overall Rank
433 | 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.00035714897
314 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00028059664
536 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020651621
945 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.0001512921
1,549 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011407374
1,788 StreamRec: A Real-Time Recommender System 2011 SIGMOD 0.00010541173
1,995 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.83817e-05
2,124 Semantics and Evaluation Techniques for Window Aggregates in Data Streams 2005 SIGMOD 9.4824543e-05
2,204 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2986554e-05
2,884 Microsoft CEP Server and Online Behavioral Targeting 2009 VLDB 7.9658952e-05
3,166 On-the-fly Progress Detection in Iterative Stream Queries 2009 VLDB 7.4575531e-05
3,240 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.3277881e-05
3,572 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 6.9525352e-05
3,818 High-Performance Dynamic Pattern Matching over Disordered Streams 2010 VLDB 6.7279318e-05
4,810 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 5.9018713e-05
4,824 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 5.8902451e-05
5,172 Active Complex Event Processing over Event Streams 2011 VLDB 5.6414491e-05
5,501 To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams 2021 SIGMOD 5.4731481e-05
5,942 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 5.2591128e-05
6,133 Optimal and General Out-of-Order Sliding-Window Aggregation 2019 VLDB 5.1917864e-05
6,148 Recognizing Patterns in Streams with Imprecise Timestamps 2010 VLDB 5.1838459e-05
6,726 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 4.9444528e-05
6,769 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 4.9274854e-05
7,280 Update-Pattern-Aware Modeling and Processing of Continuous Queries 2005 SIGMOD 4.7718173e-05
7,795 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 4.6446115e-05
7,860 Safety Guarantee of Continuous Join Queries over Punctuated Data Streams 2006 VLDB 4.6297296e-05
8,344 Event Trend Aggregation Under Rich Event Matching Semantics 2019 SIGMOD 4.5363237e-05
8,799 DLACEP: A Deep-Learning Based Framework for Approximate Complex Event Processing 2022 SIGMOD 4.4441194e-05
9,126 Differentially Private Stream Processing at Scale* 2024 VLDB 4.3870625e-05
9,323 Disaggregated State Management in Apache Flink® 2.0 2025 VLDB 4.351469e-05
9,588 Data Integration and Data Exchange: It’s Really About Time 2013 CIDR 4.3175708e-05
9,651 Dynamic Graph Databases with Out-of-order Updates 2024 VLDB 4.3067693e-05
10,772 Scribe: How Meta transports terabytes per second in real time 2025 VLDB 4.1905499e-05
11,471 Klink: Progress-Aware Scheduling for Streaming Data Systems 2021 SIGMOD 4.1905499e-05
12,321 Supporting a Spectrum of Out-of-Order Event Processing Technologies: From Aggressive to Conservative Methodologies 2009 SIGMOD 4.1905499e-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.00073944756
294 A Taxonomy of Time in Databases 1985 SIGMOD 0.00028649864
626 Sequence Query Processing 1994 SIGMOD 0.00018961452
1,136 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00013745517
1,318 Real-Time Databases 1991 VLDB 0.00012609341
Previous Page 1 / 1 Next

Semantically Similar Papers

Overall Rank Paper Year Venue Pagerank
2,204 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2986554e-05
1,006 Adaptive Filters for Continuous Queries over Distributed Data Streams 2003 SIGMOD 0.00014684829
1,141 Consistent Streaming Through Time: A Vision for Event Stream Processing 2007 CIDR 0.00013703749
7,329 Streaming in a Connected World: Querying and Tracking Distributed Data Streams 2007 SIGMOD 4.7559363e-05
4,789 Consistency in a Stream Warehouse 2011 CIDR 5.9144227e-05
43 Models and Issues in Data Stream Systems 2002 PODS 0.00072660894
3,240 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.3277881e-05
8,721 Robust Real-time Query Processing with QStream 2005 VLDB 4.4558332e-05
13,591 Scheduling Continuous Queries in Data Stream Management Systems 2008 VLDB -
8,678 Efficient Scheduling of Heterogeneous Continuous Queries 2006 VLDB 4.4644955e-05