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: 6222
Venue: SIGMOD
Year: 2021
Pagerank: 5.1488731e-05
Overall Rank: 10,102 | 30.70%
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,504	Enabling Window-Based Monotonic Graph Analytics with Reusable Transitional Results for Pattern-Consistent Queries	2024	VLDB	5.4132367e-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
220	Storm @Twitter	2014	SIGMOD	0.00024244587
710	Trill: A High-Performance Incremental Query Processor for Diverse Analytics	2015	VLDB	0.00014715033
1,067	Hadoop-GIS: A High Performance Spatial Data Warehousing System over MapReduce	2013	VLDB	0.00012327784
1,353	SPADE: The System S Declarative Stream Processing Engine	2008	SIGMOD	0.00011061346
1,369	How Soccer Players Would do Stream Joins	2011	SIGMOD	0.0001099892
2,667	A Memory Bandwidth-Efficient Hybrid Radix Sort on GPUs	2017	SIGMOD	8.2756346e-05
2,886	Approximate NN Queries on Streams with Guaranteed Error/performance Bounds	2004	VLDB	7.9957585e-05
3,378	A Hybrid B+-tree as Solution for In-Memory Indexing on CPU-GPU Heterogeneous Computing Platforms	2016	SIGMOD	7.4587887e-05
3,532	Scalable Distributed Stream Join Processing	2015	SIGMOD	7.3369085e-05
3,851	Analyzing Efficient Stream Processing on Modern Hardware	2019	VLDB	7.0735328e-05
4,279	Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines	2020	SIGMOD	6.7865878e-05
5,310	Low-Latency Handshake Join	2014	VLDB	6.2702891e-05
5,395	AQWA: Adaptive Query-Workload-Aware Partitioning of Big Spatial Data	2015	VLDB	6.2331619e-05
6,012	Parallel Index-based Stream Join on a Multicore CPU	2020	SIGMOD	6.0102675e-05
7,042	Location-Aware Pub/Sub System: When Continuous Moving Queries Meet Dynamic Event Streams	2015	SIGMOD	5.7189999e-05
7,217	ParPaRaw: Massively Parallel Parsing of Delimiter-Separated Raw Data	2020	VLDB	5.668373e-05
8,787	Adaptive Location Constraint Processing	2007	SIGMOD	5.3729697e-05
9,143	Processing Proximity Relations in Road Networks	2010	SIGMOD	5.3153925e-05

Semantically Similar Papers

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