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.00018370788
Overall Rank
433 | 97.10%
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
128 The Design of the Borealis Stream Processing Engine 2005 CIDR 0.00030317705
219 MillWheel: Fault-Tolerant Stream Processing at Internet Scale 2013 VLDB 0.0002429959
328 The Dataflow Model: A Practical Approach to Balancing Correctness, Latency, and Cost in Massive-Scale, Unbounded, Out-of-Order Data Processing 2015 VLDB 0.00020889528
762 Cayuga: A General Purpose Event Monitoring System 2007 CIDR 0.00014179183
1,202 Out-of-Order Processing: A New Architecture for High-Performance Stream Systems 2008 VLDB 0.00011523108
1,680 Semantics and Evaluation Techniques for Window Aggregates in Data Streams 2005 SIGMOD 9.8853739e-05
1,841 Fault-Tolerance in the Borealis Distributed Stream Processing System 2005 SIGMOD 9.5155524e-05
1,997 Continuous Analytics Over Discontinuous Streams 2010 SIGMOD 9.217553e-05
2,539 Microsoft CEP Server and Online Behavioral Targeting 2009 VLDB 8.303646e-05
3,006 StreamRec: A Real-Time Recommender System 2011 SIGMOD 7.7453574e-05
3,268 SECRET: A Model for Analysis of the Execution Semantics of Stream Processing Systems 2010 VLDB 7.4653816e-05
3,336 A Heartbeat Mechanism and its Application in Gigascope 2005 VLDB 7.4006534e-05
3,410 High-Performance Dynamic Pattern Matching over Disordered Streams 2010 VLDB 7.3075605e-05
4,120 On-the-fly Progress Detection in Iterative Stream Queries 2009 VLDB 6.783316e-05
4,475 Consistency and Completeness: Rethinking Distributed Stream Processing in Apache Kafka 2021 SIGMOD 6.5699934e-05
4,536 Massively Multi-Query Join Processing in Publish/Subscribe Systems 2007 SIGMOD 6.5403189e-05
4,889 Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows 2021 SIGMOD 6.3513193e-05
5,081 Active Complex Event Processing over Event Streams 2011 VLDB 6.2685571e-05
5,250 To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams 2021 SIGMOD 6.197923e-05
5,861 Optimal and General Out-of-Order Sliding-Window Aggregation 2019 VLDB 5.9505926e-05
5,912 Recognizing Patterns in Streams with Imprecise Timestamps 2010 VLDB 5.9332754e-05
6,281 Beyond Analytics: The Evolution of Stream Processing Systems 2020 SIGMOD 5.8083033e-05
6,635 Watermarks in Stream Processing Systems: Semantics and Comparative Analysis of Apache Flink and Google Cloud Dataflow 2021 VLDB 5.7098902e-05
7,485 Update-Pattern-Aware Modeling and Processing of Continuous Queries 2005 SIGMOD 5.5003667e-05
7,773 Quality-Driven Continuous Query Execution over Out-of-Order Data Streams 2015 SIGMOD 5.4388958e-05
8,289 Safety Guarantee of Continuous Join Queries over Punctuated Data Streams 2006 VLDB 5.3446379e-05
8,512 Event Trend Aggregation Under Rich Event Matching Semantics 2019 SIGMOD 5.3115496e-05
8,977 Differentially Private Stream Processing at Scale 2024 VLDB 5.2336589e-05
9,019 DLACEP: A Deep-Learning Based Framework for Approximate Complex Event Processing 2022 SIGMOD 5.2221888e-05
9,683 Disaggregated State Management in Apache Flink 2.0 2025 VLDB 5.1258854e-05
9,936 Data Integration and Data Exchange: It’s Really About Time 2013 CIDR 5.0936191e-05
10,001 Dynamic Graph Databases with Out-of-order Updates 2024 VLDB 5.0845476e-05
11,431 Scribe: How Meta transports terabytes per second in real time 2025 VLDB 4.9605343e-05
12,022 Klink: Progress-Aware Scheduling for Streaming Data Systems 2021 SIGMOD 4.9605343e-05
12,846 Supporting a Spectrum of Out-of-Order Event Processing Technologies: From Aggressive to Conservative Methodologies 2009 SIGMOD 4.9605343e-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.00053734242
341 A Taxonomy of Time in Databases 1985 SIGMOD 0.00020516619
712 Sequence Query Processing 1994 SIGMOD 0.00014588907
1,052 Chain: Operator Scheduling for Memory Minimization in Data Stream Systems 2003 SIGMOD 0.00012262678
1,778 Real-Time Databases 1991 VLDB 9.6646435e-05
Previous Page 1 / 1 Next

Semantically Similar Papers