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
- 5697
- Venue
- SIGMOD
- Year
- 2019
- Pagerank
- 4.9304882e-05
- Overall Rank
- 6,760 | 53.02%
- 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,925 |
Shared Arrangements: practical inter-query sharing for streaming dataflows |
2020 |
VLDB |
5.818597e-05 |
| 5,438 |
The NebulaStream Platform: Data and Application Management for the Internet of Things |
2020 |
CIDR |
5.5041764e-05 |
| 5,501 |
To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams |
2021 |
SIGMOD |
5.4731481e-05 |
| 7,699 |
Resource-efficient Shared Query Execution via Exploiting Time Slackness |
2021 |
SIGMOD |
4.6696504e-05 |
| 8,078 |
AJoin: Ad-hoc Stream Joins at Scale |
2020 |
VLDB |
4.5873626e-05 |
| 8,610 |
Efficient Incrementialization of Correlated Nested Aggregate Queries using Relative Partial Aggregate Indexes (RPAI) |
2022 |
SIGMOD |
4.480988e-05 |
| 9,800 |
Dalton: Learned Partitioning for Distributed Data Streams |
2023 |
VLDB |
4.2777144e-05 |
| 10,286 |
Incremental Stream Query Deployment under Continuous Infrastructure Changes in the Cloud-Edge Continuum |
2026 |
VLDB |
4.1905499e-05 |
| 10,624 |
Unraveling the Impact of Window Semantics: Optimizing Join Order for Efficient Stream Processing |
2025 |
VLDB |
4.1905499e-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.0040465394 |
| 66 |
Spark SQL: Relational Data Processing in Spark |
2015 |
SIGMOD |
0.00061707583 |
| 116 |
Eddies: Continuously Adaptive Query Processing |
2000 |
SIGMOD |
0.00046191288 |
| 244 |
Continuously Adaptive Continuous Queries over Streams |
2002 |
SIGMOD |
0.00031037999 |
| 287 |
Storm @Twitter |
2014 |
SIGMOD |
0.00028917909 |
| 515 |
QPipe: A Simultaneously Pipelined Relational Query Engine |
2005 |
SIGMOD |
0.00021209491 |
| 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 |
| 934 |
SharedDB: Killing One Thousand Queries With One Stone |
2012 |
VLDB |
0.00015201246 |
| 1,027 |
Cooperative Scans: Dynamic Bandwidth Sharing in a DBMS |
2007 |
VLDB |
0.0001458537 |
| 1,097 |
Trill: A High-Performance Incremental Query Processor for Diverse Analytics |
2015 |
VLDB |
0.00014083973 |
| 1,296 |
The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses |
2010 |
SIGMOD |
0.00012742585 |
| 1,430 |
A Scalable, Predictable Join Operator for Highly Concurrent Data Warehouses |
2009 |
VLDB |
0.0001202506 |
| 1,503 |
BatchDB: Efficient Isolated Execution of Hybrid OLTP+OLAP Workloads for Interactive Applications |
2017 |
SIGMOD |
0.0001161148 |
| 1,546 |
Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark |
2018 |
SIGMOD |
0.00011418993 |
| 1,791 |
On-the-Fly Sharing for Streamed Aggregation |
2006 |
SIGMOD |
0.0001052731 |
| 1,956 |
On the Design and Scalability of Distributed Shared-Data Databases |
2015 |
SIGMOD |
9.9626473e-05 |
| 2,124 |
Semantics and Evaluation Techniques for Window Aggregates in Data Streams |
2005 |
SIGMOD |
9.4824543e-05 |
| 2,372 |
Predictable Performance for Unpredictable Workloads |
2009 |
VLDB |
8.940791e-05 |
| 2,928 |
Shared Workload Optimization |
2014 |
VLDB |
7.881485e-05 |
| 3,138 |
Scheduling for shared window joins over data streams |
2003 |
VLDB |
7.4919127e-05 |
| 3,551 |
Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems |
2018 |
VLDB |
6.9776252e-05 |
| 4,677 |
To Share or Not to Share? |
2007 |
VLDB |
5.9988869e-05 |
| 4,964 |
Sharing Data and Work Across Concurrent Analytical Queries |
2013 |
VLDB |
5.7974073e-05 |
| 5,298 |
MQJoin: Efficient Shared Execution of Main-Memory Joins |
2016 |
VLDB |
5.5762694e-05 |
| 5,766 |
Building a Replicated Logging System with Apache Kafka |
2015 |
VLDB |
5.3353079e-05 |
| 6,062 |
OLTPShare: The Case for Sharing in OLTP Workloads |
2018 |
VLDB |
5.2267464e-05 |
| 6,871 |
State-Slice: New Paradigm of Multi-query Optimization of Window-based Stream Queries |
2006 |
VLDB |
4.8966771e-05 |
Semantically Similar Papers
| Overall Rank |
Paper |
Year |
Venue |
Pagerank |
| 11,471 |
Klink: Progress-Aware Scheduling for Streaming Data Systems |
2021 |
SIGMOD |
4.1905499e-05 |
| 6,469 |
Parallel Index-based Stream Join on a Multicore CPU |
2020 |
SIGMOD |
5.0448159e-05 |
| 1,343 |
Scalable Distributed Stream Processing |
2003 |
CIDR |
0.00012478318 |
| 7,658 |
Scalable Delivery of Stream Query Result |
2009 |
VLDB |
4.6817213e-05 |
| 4,161 |
Scalable Distributed Stream Join Processing |
2015 |
SIGMOD |
6.3883784e-05 |
| 7,105 |
StreaMon: An Adaptive Engine for Stream Query Processing |
2004 |
SIGMOD |
4.8252304e-05 |
| 10,970 |
Low-Latency Adaptive Distributed Stream Join System Based on a Flexible Join Model |
2024 |
SIGMOD |
4.1905499e-05 |
| 1,791 |
On-the-Fly Sharing for Streamed Aggregation |
2006 |
SIGMOD |
0.0001052731 |
| 4,925 |
Shared Arrangements: practical inter-query sharing for streaming dataflows |
2020 |
VLDB |
5.818597e-05 |
| 8,078 |
AJoin: Ad-hoc Stream Joins at Scale |
2020 |
VLDB |
4.5873626e-05 |