Distributed Stream KNN Join

Summary: ADS-kNN: adaptive, scalable stream kNN join for highly dynamic data streams. A staged plan overlapping compute and communication with adaptive data partitioning to balance load, delivering up to 21x throughput on a 56-core system vs single-threaded. (summarized by gpt-5-nano on Feb 09 2026)

Paper ID: h01b9101a52de3fe5
Venue: SIGMOD
Year: 2021
Pagerank: 5.014328e-05
Overall Rank: 10,362 | 30.55%
DOI: 10.1145/3448016.3457269

Incoming Non-self Citations Over Time

Authors

1. Amirhesam Shahvarani (Technical University of Munich)
2. Hans-Arno Jacobsen (University of Toronto)

BibTeX Citation

@inproceedings{shahvarani_sigmod21,
        title = {{Distributed Stream KNN Join}},
        author = {Shahvarani, Amirhesam and Jacobsen, Hans-Arno},
        series = {{SIGMOD} '21},
        booktitle = {Proceedings of the {ACM} {SIGMOD} International Conference on Management of Data},
        publisher = {Association for Computing Machinery},
        doi = {10.1145/3448016.3457269},
        url = {https://dl.acm.org/doi/10.1145/3448016.3457269},
        year = {2021}
}

Incoming Citations (Sorted by Pagerank)

Showing 1 of 1 citing papers.

Rank	Citing Paper	Year	Venue	Pagerank
8,699	Enabling Window-Based Monotonic Graph Analytics with Reusable Transitional Results for Pattern-Consistent Queries	2024	VLDB	5.2717835e-05

Outgoing Citations (Sorted by Pagerank)

Showing 18 of 18 cited papers.

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

Rank	Cited Paper	Year	Venue	Pagerank
233	Storm @Twitter	2014	SIGMOD	0.00023754096
688	Trill: A High-Performance Incremental Query Processor for Diverse Analytics	2015	VLDB	0.00014736145
1,084	Hadoop-GIS: A High Performance Spatial Data Warehousing System over MapReduce	2013	VLDB	0.00012086348
1,390	SPADE: The System S Declarative Stream Processing Engine	2008	SIGMOD	0.00010802626
1,391	How Soccer Players Would do Stream Joins	2011	SIGMOD	0.00010790581
2,485	A Memory Bandwidth-Efficient Hybrid Radix Sort on GPUs	2017	SIGMOD	8.3800709e-05
2,952	Approximate NN Queries on Streams with Guaranteed Error/performance Bounds	2004	VLDB	7.8061763e-05
3,383	A Hybrid B+-tree as Solution for In-Memory Indexing on CPU-GPU Heterogeneous Computing Platforms	2016	SIGMOD	7.3393628e-05
3,610	Scalable Distributed Stream Join Processing	2015	SIGMOD	7.1463915e-05
3,939	Analyzing Efficient Stream Processing on Modern Hardware	2019	VLDB	6.8967981e-05
4,129	Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines	2020	SIGMOD	6.7751787e-05
5,455	Low-Latency Handshake Join	2014	VLDB	6.107413e-05
5,554	AQWA: Adaptive Query-Workload-Aware Partitioning of Big Spatial Data	2015	VLDB	6.0707181e-05
6,079	ParPaRaw: Massively Parallel Parsing of Delimiter-Separated Raw Data	2020	VLDB	5.8759961e-05
6,139	Parallel Index-based Stream Join on a Multicore CPU	2020	SIGMOD	5.8567401e-05
7,209	Location-Aware Pub/Sub System: When Continuous Moving Queries Meet Dynamic Event Streams	2015	SIGMOD	5.5695569e-05
8,981	Adaptive Location Constraint Processing	2007	SIGMOD	5.2326057e-05
9,347	Processing Proximity Relations in Road Networks	2010	SIGMOD	5.176541e-05

Semantically Similar Papers

#	Overall Rank	Paper	Year	Venue
1	12,432	Let's Rethink Join Optimization in Distributed Systems	2015	CIDR
2	6,168	Similarity Join over Array Data	2016	SIGMOD
3	3,391	Ad-hoc Top-k Query Answering for Data Streams	2007	VLDB
4	2,183	Efficient Processing of k Nearest Neighbor Joins using MapReduce	2012	VLDB
5	2,806	Distributed Join Algorithms on Thousands of Cores	2017	VLDB
6	6,139	Parallel Index-based Stream Join on a Multicore CPU	2020	SIGMOD
7	2,972	Scalable and Adaptive Online Joins	2014	VLDB
8	3,610	Scalable Distributed Stream Join Processing	2015	SIGMOD
9	2,952	Approximate NN Queries on Streams with Guaranteed Error/performance Bounds	2004	VLDB
10	11,580	Low-Latency Adaptive Distributed Stream Join System Based on a Flexible Join Model	2024	SIGMOD