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.737728e-05
Overall Rank
6,601 | 55.64%
DOI
10.1145/3299869.3319884
Incoming Non-self Citations Over Time
Authors
1.
Jeyhun Karimov
(German National Research Center for Information Technology)
2.
Tilmann Rabl
(German National Research Center for Information Technology; Technical University of Berlin)
3.
Volker Markl
(German National Research Center for Information Technology; Technical University of Berlin)
BibTeX Citation
Copy BibTeX
@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,402
Shared Arrangements: practical inter-query sharing for streaming dataflows
2020
VLDB
6.6120647e-05
5,226
To Share, or not to Share Online Event Trend Aggregation Over Bursty Event Streams
2021
SIGMOD
6.2184852e-05
5,349
The NebulaStream Platform: Data and Application Management for the Internet of Things
2020
CIDR
6.1679453e-05
7,728
Resource-efficient Shared Query Execution via Exploiting Time Slackness
2021
SIGMOD
5.4649863e-05
8,019
AJoin: Ad-hoc Stream Joins at Scale
2020
VLDB
5.4045347e-05
8,567
Efficient Incrementialization of Correlated Nested Aggregate Queries using Relative Partial Aggregate Indexes (RPAI)
2022
SIGMOD
5.3118554e-05
9,209
Dalton: Learned Partitioning for Distributed Data Streams
2023
VLDB
5.2060149e-05
10,783
Incremental Stream Query Deployment under Continuous Infrastructure Changes in the Cloud-Edge Continuum
2026
VLDB
4.9769913e-05
11,284
Unraveling the Impact of Window Semantics: Optimizing Join Order for Efficient Stream Processing
2025
VLDB
4.9769913e-05
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.0023943337
23
Spark SQL: Relational Data Processing in Spark
2015
SIGMOD
0.00055384955
53
Eddies: Continuously Adaptive Query Processing
2000
SIGMOD
0.000408505
200
Continuously Adaptive Continuous Queries over Streams
2002
SIGMOD
0.00025444144
231
Storm @Twitter
2014
SIGMOD
0.00023830094
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.0002095522
390
QPipe: A Simultaneously Pipelined Relational Query Engine
2005
SIGMOD
0.00019265472
669
SharedDB: Killing One Thousand Queries With One Stone
2012
VLDB
0.00014975391
685
Trill: A High-Performance Incremental Query Processor for Diverse Analytics
2015
VLDB
0.00014778299
762
Cooperative Scans: Dynamic Bandwidth Sharing in a DBMS
2007
VLDB
0.00014134432
1,034
A Scalable, Predictable Join Operator for Highly Concurrent Data Warehouses
2009
VLDB
0.00012389548
1,040
The DataPath System: A Data-Centric Analytic Processing Engine for Large Data Warehouses
2010
SIGMOD
0.00012358804
1,123
Structured Streaming: A Declarative API for Real-Time Applications in Apache Spark
2018
SIGMOD
0.00011926683
1,242
BatchDB: Efficient Isolated Execution of Hybrid OLTP+OLAP Workloads for Interactive Applications
2017
SIGMOD
0.00011378275
1,383
On-the-Fly Sharing for Streamed Aggregation
2006
SIGMOD
0.00010842596
1,402
State Management in Apache Flink: Consistent Stateful Distributed Stream Processing
2017
VLDB
0.00010766851
1,583
On the Design and Scalability of Distributed Shared-Data Databases
2015
SIGMOD
0.00010165157
1,674
Semantics and Evaluation Techniques for Window Aggregates in Data Streams
2005
SIGMOD
9.9177225e-05
1,918
Predictable Performance for Unpredictable Workloads
2009
VLDB
9.375192e-05
2,225
Shared Workload Optimization
2014
VLDB
8.8062552e-05
2,782
Scheduling for shared window joins over data streams
2003
VLDB
8.0214634e-05
3,034
Chi: A Scalable and Programmable Control Plane for Distributed Stream Processing Systems
2018
VLDB
7.7301387e-05
4,393
Sharing Data and Work Across Concurrent Analytical Queries
2013
VLDB
6.618354e-05
4,579
To Share or Not to Share?
2007
VLDB
6.5205268e-05
4,732
MQJoin: Efficient Shared Execution of Main-Memory Joins
2016
VLDB
6.4439712e-05
5,029
Building a Replicated Logging System with Apache Kafka
2015
VLDB
6.3058391e-05
5,793
OLTPShare: The Case for Sharing in OLTP Workloads
2018
VLDB
5.9906809e-05
6,659
State-Slice: New Paradigm of Multi-query Optimization of Window-based Stream Queries
2006
VLDB
5.7166466e-05
Semantically Similar Papers
#
Overall Rank
Paper
Year
Venue
1
11,978
Klink: Progress-Aware Scheduling for Streaming Data Systems
2021
SIGMOD
2
6,125
Parallel Index-based Stream Join on a Multicore CPU
2020
SIGMOD
3
1,101
Scalable Distributed Stream Processing
2003
CIDR
4
8,832
Scalable Delivery of Stream Query Result
2009
VLDB
5
3,603
Scalable Distributed Stream Join Processing
2015
SIGMOD
6
7,437
StreaMon: An Adaptive Engine for Stream Query Processing
2004
SIGMOD
7
11,531
Low-Latency Adaptive Distributed Stream Join System Based on a Flexible Join Model
2024
SIGMOD
8
1,383
On-the-Fly Sharing for Streamed Aggregation
2006
SIGMOD
9
4,402
Shared Arrangements: practical inter-query sharing for streaming dataflows
2020
VLDB
10
8,019
AJoin: Ad-hoc Stream Joins at Scale
2020
VLDB