DBScholar

Back to papers

AStream: Ad-hoc Shared Stream Processing

Summary: First distributed ad-hoc shared stream processing framework on Apache Flink, enabling multi-tenant ad-hoc queries to share computation. Composable integration for joins, aggregations, and windows with exactly-once, incremental execution; yields high throughput for many concurrent queries (comparable to Flink for one query, orders of magnitude better for many). (summarized by gpt-5-nano on Feb 09 2026)

Paper ID
h4ebde4e37c7d5cd0
Venue
SIGMOD
Year
2019
Pagerank
5.7187564e-05
Overall Rank
6,607 | 55.72%
DOI
10.1145/3299869.3319884

Incoming Non-self Citations Over Time

Authors

BibTeX Citation

@inproceedings{karimov_sigmod19,
        title = {{AStream: Ad-hoc Shared Stream Processing}},
        author = {Karimov, Jeyhun and Rabl, Tilmann and Markl, Volker},
        series = {{SIGMOD} '19},
        booktitle = {Proceedings of the {ACM} {SIGMOD} International Conference on Management of Data},
        publisher = {Association for Computing Machinery},
        doi = {10.1145/3299869.3319884},
        url = {https://dl.acm.org/doi/10.1145/3299869.3319884},
        year = {2019}
}

Incoming Citations (Sorted by Pagerank)

Showing 9 of 9 citing papers.

Rank Citing Paper Year Venue Pagerank
4,422 Shared Arrangements: practical inter-query sharing for streaming dataflows 2020 VLDB 6.5902096e-05
5,250 To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams 2021 SIGMOD 6.197923e-05
5,363 The NebulaStream Platform: Data and Application Management for the Internet of Things 2020 CIDR 6.1475521e-05
7,741 Resource-efficient Shared Query Execution via Exploiting Time Slackness 2021 SIGMOD 5.4469162e-05
8,035 AJoin: Ad-hoc Stream Joins at Scale 2020 VLDB 5.3866645e-05
8,585 Efficient Incrementialization of Correlated Nested Aggregate Queries using Relative Partial Aggregate Indexes (RPAI) 2022 SIGMOD 5.2943199e-05
9,232 Dalton: Learned Partitioning for Distributed Data Streams 2023 VLDB 5.1888006e-05
10,844 Incremental Stream Query Deployment under Continuous Infrastructure Changes in the Cloud-Edge Continuum 2026 VLDB 4.9605343e-05
11,340 Unraveling the Impact of Window Semantics: Optimizing Join Order for Efficient Stream Processing 2025 VLDB 4.9605343e-05
Previous Page 1 / 1 Next

Outgoing Citations (Sorted by Pagerank)

Showing 28 of 28 cited papers.

Citations counted here include only citations to other VLDB/SIGMOD/CIDR/PODS papers in this database.

Rank Cited Paper Year Venue Pagerank
1 Access Path Selection in a Relational Database Management System 1979 SIGMOD 0.0023948467
23 Spark SQL: Relational Data Processing in Spark 2015 SIGMOD 0.00055523999
53 Eddies: Continuously Adaptive Query Processing 2000 SIGMOD 0.00040739114
201 Continuously Adaptive Continuous Queries over Streams 2002 SIGMOD 0.00025363666
233 Storm @Twitter 2014 SIGMOD 0.00023754096
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
390 QPipe: A Simultaneously Pipelined Relational Query Engine 2005 SIGMOD 0.00019232929
670 SharedDB: Killing One Thousand Queries With One Stone 2012 VLDB 0.00014929358
688 Trill: A High-Performance Incremental Query Processor for Diverse Analytics 2015 VLDB 0.00014736145
768 Cooperative Scans: Dynamic Bandwidth Sharing in a DBMS 2007 VLDB 0.00014096379
1,029 A Scalable, Predictable Join Operator for Highly Concurrent Data Warehouses 2009 VLDB 0.00012380835
1,043 The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses 2010 SIGMOD 0.00012325755
1,128 Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark 2018 SIGMOD 0.00011887295
1,232 BatchDB: Efficient Isolated Execution of Hybrid OLTP+OLAP Workloads for Interactive Applications 2017 SIGMOD 0.00011406847
1,388 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD 0.00010806922
1,409 State Management in Apache Flink: Consistent Stateful Distributed Stream Processing 2017 VLDB 0.00010732706
1,585 On the Design and Scalability of Distributed Shared-Data Databases 2015 SIGMOD 0.00010136077
1,680 Semantics and Evaluation Techniques for Window Aggregates in Data Streams 2005 SIGMOD 9.8853739e-05
1,926 Predictable Performance for Unpredictable Workloads 2009 VLDB 9.3500398e-05
2,237 Shared Workload Optimization 2014 VLDB 8.7777395e-05
2,790 Scheduling for shared window joins over data streams 2003 VLDB 7.9949781e-05
3,043 Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems 2018 VLDB 7.7045781e-05
4,411 Sharing Data and Work Across Concurrent Analytical Queries 2013 VLDB 6.5996653e-05
4,594 To Share or Not to Share? 2007 VLDB 6.4994689e-05
4,751 MQJoin: Efficient Shared Execution of Main-Memory Joins 2016 VLDB 6.42279e-05
5,053 Building a Replicated Logging System with Apache Kafka 2015 VLDB 6.2849881e-05
5,807 OLTPShare: The Case for Sharing in OLTP Workloads 2018 VLDB 5.9709922e-05
6,671 State-Slice: New Paradigm of Multi-query Optimization of Window-based Stream Queries 2006 VLDB 5.6977582e-05
Previous Page 1 / 1 Next

Semantically Similar Papers

# Overall Rank Paper Year Venue
1 12,022 Klink: Progress-Aware Scheduling for Streaming Data Systems 2021 SIGMOD
2 6,139 Parallel Index-based Stream Join on a Multicore CPU 2020 SIGMOD
3 1,105 Scalable Distributed Stream Processing 2003 CIDR
4 8,850 Scalable Delivery of Stream Query Result 2009 VLDB
5 3,610 Scalable Distributed Stream Join Processing 2015 SIGMOD
6 7,458 StreaMon: An Adaptive Engine for Stream Query Processing 2004 SIGMOD
7 11,580 Low-Latency Adaptive Distributed Stream Join System Based on a Flexible Join Model 2024 SIGMOD
8 1,388 On-the-Fly Sharing for Streamed Aggregation 2006 SIGMOD
9 4,422 Shared Arrangements: practical inter-query sharing for streaming dataflows 2020 VLDB
10 8,035 AJoin: Ad-hoc Stream Joins at Scale 2020 VLDB