DBScholar

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
h11901245f60d73cf
Venue
PODS
Year
2004
Pagerank
0.00018439857
Overall Rank
429 | 97.12%
DOI
10.1145/1055558.1055596

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@inproceedings{srivastava_pods04,
        address = {New York, NY, USA},
        series = {{PODS} '04},
        title = {{Flexible Time Management in Data Stream Systems}},
        url = {https://dl.acm.org/doi/10.1145/1055558.1055596},
        doi = {10.1145/1055558.1055596},
        booktitle = {Proceedings of the {ACM} {SIGMOD} Symposium on {Principles} of {Database} {Systems}},
        publisher = {Association for Computing Machinery},
        author = {Srivastava, Utkarsh and Widom, Jennifer},
        year = {2004}
}

Incoming Citations (Sorted by Pagerank)

Showing 35 of 35 citing papers.

Rank Citing Paper Year Venue Pagerank
127 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00030427614
218 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.00024390324
325 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020964941
755 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00014232741
1,197 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011566535
1,674 Semantics and Evaluation Techniques for Window Aggregates in Data Streams 2005 SIGMOD 9.922398e-05
1,828 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.5516021e-05
1,985 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.2521678e-05
2,532 Microsoft CEP Server and Online Behavioral Targeting 2009 VLDB 8.3350246e-05
2,990 StreamRec: A Real-Time Recommender System 2011 SIGMOD 7.7745392e-05
3,251 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 7.4932341e-05
3,324 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.4285048e-05
3,400 High-Performance Dynamic Pattern Matching over Disordered Streams 2010 VLDB 7.3336355e-05
4,098 On-the-fly Progress Detection in Iterative Stream Queries 2009 VLDB 6.8090144e-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,866 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 6.3754084e-05
5,059 Active Complex Event Processing over Event Streams 2011 VLDB 6.2917112e-05
5,222 To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams 2021 SIGMOD 6.2214303e-05
5,843 Optimal and General Out-of-Order Sliding-Window Aggregation 2019 VLDB 5.9731599e-05
5,895 Recognizing Patterns in Streams with Imprecise Timestamps 2010 VLDB 5.9557639e-05
6,266 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8303329e-05
6,620 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 5.7315465e-05
7,462 Update-Pattern-Aware Modeling and Processing of Continuous Queries 2005 SIGMOD 5.521211e-05
7,751 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 5.4595244e-05
8,267 Safety Guarantee of Continuous Join Queries over Punctuated Data Streams 2006 VLDB 5.3648996e-05
8,489 Event Trend Aggregation Under Rich Event Matching Semantics 2019 SIGMOD 5.3316951e-05
8,945 Differentially Private Stream Processing at Scale 2024 VLDB 5.253509e-05
8,992 DLACEP: A Deep-Learning Based Framework for Approximate Complex Event Processing 2022 SIGMOD 5.2419954e-05
9,648 Disaggregated State Management in Apache Flink 2.0 2025 VLDB 5.1453267e-05
9,894 Data Integration and Data Exchange: It’s Really About Time 2013 CIDR 5.1129187e-05
9,964 Dynamic Graph Databases with Out-of-order Updates 2024 VLDB 5.1038322e-05
11,372 Scribe: How Meta transports terabytes per second in real time 2025 VLDB 4.9793485e-05
11,972 Klink: Progress-Aware Scheduling for Streaming Data Systems 2021 SIGMOD 4.9793485e-05
12,797 Supporting a Spectrum of Out-of-Order Event Processing Technologies: From Aggressive to Conservative Methodologies 2009 SIGMOD 4.9793485e-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
25 NiagaraCQ: A Scalable Continuous Query System for Internet Databases 2000 SIGMOD 0.00053930011
339 A Taxonomy of Time in Databases 1985 SIGMOD 0.00020570509
706 Sequence Query Processing 1994 SIGMOD 0.00014643264
1,047 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00012308922
1,762 Real-Time Databases 1991 VLDB 9.7006836e-05
Previous Page 1 / 1 Next

Semantically Similar Papers