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.0309635e-05
Overall Rank: 10,336 | 30.54%
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,679	Enabling Window-Based Monotonic Graph Analytics with Reusable Transitional Results for Pattern-Consistent Queries	2024	VLDB	5.2892731e-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
231	Storm @Twitter	2014	SIGMOD	0.00023830094
685	Trill: A High-Performance Incremental Query Processor for Diverse Analytics	2015	VLDB	0.00014778299
1,081	Hadoop-GIS: A High Performance Spatial Data Warehousing System over MapReduce	2013	VLDB	0.00012126286
1,386	SPADE: The System S Declarative Stream Processing Engine	2008	SIGMOD	0.00010838275
1,388	How Soccer Players Would do Stream Joins	2011	SIGMOD	0.00010820564
2,487	A Memory Bandwidth-Efficient Hybrid Radix Sort on GPUs	2017	SIGMOD	8.3939994e-05
2,940	Approximate NN Queries on Streams with Guaranteed Error/performance Bounds	2004	VLDB	7.8306095e-05
3,374	A Hybrid B+-tree as Solution for In-Memory Indexing on CPU-GPU Heterogeneous Computing Platforms	2016	SIGMOD	7.3606793e-05
3,603	Scalable Distributed Stream Join Processing	2015	SIGMOD	7.1701004e-05
3,923	Analyzing Efficient Stream Processing on Modern Hardware	2019	VLDB	6.919667e-05
4,110	Rhino: Efficient Management of Very Large Distributed State for Stream Processing Engines	2020	SIGMOD	6.797656e-05
5,439	Low-Latency Handshake Join	2014	VLDB	6.1276749e-05
5,529	AQWA: Adaptive Query-Workload-Aware Partitioning of Big Spatial Data	2015	VLDB	6.0908508e-05
6,064	ParPaRaw: Massively Parallel Parsing of Delimiter-Separated Raw Data	2020	VLDB	5.8954903e-05
6,125	Parallel Index-based Stream Join on a Multicore CPU	2020	SIGMOD	5.8761704e-05
7,191	Location-Aware Pub/Sub System: When Continuous Moving Queries Meet Dynamic Event Streams	2015	SIGMOD	5.5880344e-05
8,958	Adaptive Location Constraint Processing	2007	SIGMOD	5.2499352e-05
9,322	Processing Proximity Relations in Road Networks	2010	SIGMOD	5.1937083e-05

Semantically Similar Papers

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