From 161dfc0ef7c49df8dc3806b8fb30225e6993915e Mon Sep 17 00:00:00 2001 From: imDema Date: Tue, 11 Jun 2024 15:33:19 +0200 Subject: [PATCH] Glidesort for sort merge join --- src/operator/join/local_sort_merge.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/operator/join/local_sort_merge.rs b/src/operator/join/local_sort_merge.rs index 89a28ab9..1b3de007 100644 --- a/src/operator/join/local_sort_merge.rs +++ b/src/operator/join/local_sort_merge.rs @@ -187,11 +187,11 @@ impl< } StreamElement::Item(BinaryElement::LeftEnd) => { self.left_ended = true; - self.left.sort_unstable_by(|(k1, _), (k2, _)| k1.cmp(k2)); + glidesort::sort_by(&mut self.left, |(k1, _), (k2, _)| k1.cmp(k2)); } StreamElement::Item(BinaryElement::RightEnd) => { self.right_ended = true; - self.right.sort_unstable_by(|(k1, _), (k2, _)| k1.cmp(k2)); + glidesort::sort_by(&mut self.right, |(k1, _), (k2, _)| k1.cmp(k2)); } StreamElement::Timestamped(_, _) | StreamElement::Watermark(_) => { panic!("Cannot join timestamp streams")