Kontinuation commented on code in PR #573:
URL: https://github.com/apache/sedona-db/pull/573#discussion_r2766993831
##########
rust/sedona-spatial-join/src/stream.rs:
##########
@@ -106,6 +114,12 @@ pub(crate) struct SpatialJoinStream {
/// This is used for outer joins to ensure that we only emit unmatched
rows from the Multi
/// partition once, after all regular partitions have been processed.
visited_multi_probe_side: Option<Arc<Mutex<BooleanBufferBuilder>>>,
+ /// KNN results merger. Only used for partitioned KNN join. This value is
Some when this spatial join stream
+ /// is for KNN join and the number of partitions is greater than 1, except
when in the
+ /// [SpatialJoinStreamState::ProcessProbeBatch] state. The
`knn_results_merger` will be moved into the
Review Comment:
`SpatialJoinStreamState::ProcessProbeBatch` is a valid reference.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
