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
- 5696
- Venue
- SIGMOD
- Year
- 2019
- Pagerank
- 4.9352213e-05
- Overall Rank
- 6,759 | 52.98%
- DOI
-
10.1145/3299869.3319884
Incoming Non-self Citations Over Time
Incoming Citations (Sorted by Pagerank)
Showing 9 of 9 citing papers.
| Rank |
Citing Paper |
Year |
Venue |
Pagerank |
| 4,920 |
Shared Arrangements: practical inter-query sharing for streaming dataflows |
2020 |
VLDB |
5.8241888e-05 |
| 5,427 |
The NebulaStream Platform: Data and Application Management for the Internet of Things |
2020 |
CIDR |
5.509468e-05 |
| 5,489 |
To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams |
2021 |
SIGMOD |
5.4782335e-05 |
| 7,701 |
Resource-efficient Shared Query Execution via Exploiting Time Slackness |
2021 |
SIGMOD |
4.6741329e-05 |
| 8,075 |
AJoin: Ad-hoc Stream Joins at Scale |
2020 |
VLDB |
4.5917655e-05 |
| 8,611 |
Efficient Incrementialization of Correlated Nested Aggregate Queries using Relative Partial Aggregate Indexes (RPAI) |
2022 |
SIGMOD |
4.4852886e-05 |
| 9,797 |
Dalton: Learned Partitioning for Distributed Data Streams |
2023 |
VLDB |
4.2818172e-05 |
| 10,274 |
Incremental Stream Query Deployment under Continuous Infrastructure Changes in the Cloud-Edge Continuum |
2026 |
VLDB |
4.1945683e-05 |
| 10,616 |
Unraveling the Impact of Window Semantics: Optimizing Join Order for Efficient Stream Processing |
2025 |
VLDB |
4.1945683e-05 |
Outgoing Citations (Sorted by Pagerank)
Showing 27 of 27 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.0040449103 |
| 66 |
Spark SQL: Relational Data Processing in Spark |
2015 |
SIGMOD |
0.00061639801 |
| 115 |
Eddies: Continuously Adaptive Query Processing |
2000 |
SIGMOD |
0.00046221215 |
| 244 |
Continuously Adaptive Continuous Queries over Streams |
2002 |
SIGMOD |
0.00031066222 |
| 288 |
Storm @Twitter |
2014 |
SIGMOD |
0.00028939871 |
| 515 |
QPipe: A Simultaneously Pipelined Relational Query Engine |
2005 |
SIGMOD |
0.00021214633 |
| 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 |
| 940 |
SharedDB: Killing One Thousand Queries With One Stone |
2012 |
VLDB |
0.00015173166 |
| 1,026 |
Cooperative Scans: Dynamic Bandwidth Sharing in a DBMS |
2007 |
VLDB |
0.00014589172 |
| 1,098 |
Trill: A High-Performance Incremental Query Processor for Diverse Analytics |
2015 |
VLDB |
0.00014114442 |
| 1,299 |
The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses |
2010 |
SIGMOD |
0.00012751522 |
| 1,429 |
A Scalable, Predictable Join Operator for Highly Concurrent Data Warehouses |
2009 |
VLDB |
0.00012033518 |
| 1,507 |
BatchDB: Efficient Isolated Execution of Hybrid OLTP+OLAP Workloads for Interactive Applications |
2017 |
SIGMOD |
0.00011617967 |
| 1,548 |
Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark |
2018 |
SIGMOD |
0.00011431383 |
| 1,788 |
On-the-Fly Sharing for Streamed Aggregation |
2006 |
SIGMOD |
0.00010555742 |
| 1,957 |
On the Design and Scalability of Distributed Shared-Data Databases |
2015 |
SIGMOD |
9.9598319e-05 |
| 2,101 |
Semantics and Evaluation Techniques for Window Aggregates in Data Streams |
2005 |
SIGMOD |
9.5429492e-05 |
| 2,372 |
Predictable Performance for Unpredictable Workloads |
2009 |
VLDB |
8.947963e-05 |
| 2,925 |
Shared Workload Optimization |
2014 |
VLDB |
7.888494e-05 |
| 3,126 |
Scheduling for shared window joins over data streams |
2003 |
VLDB |
7.5046934e-05 |
| 3,550 |
Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems |
2018 |
VLDB |
6.9843512e-05 |
| 4,680 |
To Share or Not to Share? |
2007 |
VLDB |
6.0039406e-05 |
| 4,959 |
Sharing Data and Work Across Concurrent Analytical Queries |
2013 |
VLDB |
5.8029448e-05 |
| 5,293 |
MQJoin: Efficient Shared Execution of Main-Memory Joins |
2016 |
VLDB |
5.5815698e-05 |
| 5,753 |
Building a Replicated Logging System with Apache Kafka |
2015 |
VLDB |
5.3404371e-05 |
| 6,060 |
OLTPShare: The Case for Sharing in OLTP Workloads |
2018 |
VLDB |
5.2305257e-05 |
| 6,753 |
State-Slice: New Paradigm of Multi-query Optimization of Window-based Stream Queries |
2006 |
VLDB |
4.9387235e-05 |
Semantically Similar Papers
| Overall Rank |
Paper |
Year |
Venue |
Pagerank |
| 11,468 |
Klink: Progress-Aware Scheduling for Streaming Data Systems |
2021 |
SIGMOD |
4.1945683e-05 |
| 6,476 |
Parallel Index-based Stream Join on a Multicore CPU |
2020 |
SIGMOD |
5.0496617e-05 |
| 7,660 |
Scalable Delivery of Stream Query Result |
2009 |
VLDB |
4.6862657e-05 |
| 1,340 |
Scalable Distributed Stream Processing |
2003 |
CIDR |
0.00012489223 |
| 4,167 |
Scalable Distributed Stream Join Processing |
2015 |
SIGMOD |
6.3919506e-05 |
| 7,107 |
StreaMon: An Adaptive Engine for Stream Query Processing |
2004 |
SIGMOD |
4.8298643e-05 |
| 10,967 |
Low-Latency Adaptive Distributed Stream Join System Based on a Flexible Join Model |
2024 |
SIGMOD |
4.1945683e-05 |
| 1,788 |
On-the-Fly Sharing for Streamed Aggregation |
2006 |
SIGMOD |
0.00010555742 |
| 4,920 |
Shared Arrangements: practical inter-query sharing for streaming dataflows |
2020 |
VLDB |
5.8241888e-05 |
| 8,075 |
AJoin: Ad-hoc Stream Joins at Scale |
2020 |
VLDB |
4.5917655e-05 |